Lightweight Stream API

경량 스트림 API

Java 7 이하용 반복기로 재작성된 Java 8의 스트림 API입니다.

포함

• 기능적 인터페이스( Supplier , Function , Consumer 등)
• Stream / IntStream / LongStream / DoubleStream (병렬 처리는 없지만 다양한 추가 방법과 사용자 정의 연산자 사용)
• Optional / OptionalBoolean / OptionalInt / OptionalLong / OptionalDouble 클래스;
• Exceptional 클래스 - 예외를 처리하는 기능적인 방법입니다.
• Java 7의 Objects .

용법

 Stream . of ( /* array | list | set | map | anything based on Iterator/Iterable interface */ )
    . filter (..)
    . map (..)
    ...
    . sorted ()
    . forEach (..);
Stream . of ( value1 , value2 , value3 )...
IntStream . range ( 0 , 10 )...

예제 프로젝트: https://github.com/aNNiMON/Android-Java-8-Stream-Example

주요 기능

맞춤 연산자

Java 8 스트림과 달리 Lightweight-Stream-API는 사용자 정의 연산자를 적용하는 기능을 제공합니다.

 Stream . of (...)
    . custom ( new Reverse <>())
    . forEach (...);

public final class Reverse < T > implements UnaryOperator < Stream < T >> {

    @ Override
    public Stream < T > apply ( Stream < T > stream ) {
        final Iterator <? extends T > iterator = stream . getIterator ();
        final ArrayDeque < T > deque = new ArrayDeque < T >();
        while ( iterator . hasNext ()) {
            deque . addFirst ( iterator . next ());
        }
        return Stream . of ( deque . iterator ());
    }
}

여기에서 더 많은 예를 찾을 수 있습니다.

추가 연산자

백포트된 Java 8 Stream 연산자 외에도 라이브러리는 다음을 제공합니다.

• filterNot - 부정된 filter 연산자

   // Java 8
  stream . filter ((( Predicate < String >) String :: isEmpty ). negate ())
  // LSA
  stream . filterNot ( String :: isEmpty )

• select - 주어진 클래스의 인스턴스를 필터링합니다.

   // Java 8
  stream . filter ( Integer . class :: isInstance )
  // LSA
  stream . select ( Integer . class )

• withoutNulls - null 요소가 아닌 요소만 필터링합니다.

   Stream . of ( "a" , null , "c" , "d" , null )
      . withoutNulls () // [a, c, d]

• sortBy - 추출기 기능을 기준으로 정렬

   // Java 8
  stream . sorted ( Comparator . comparing ( Person :: getName ))
  // LSA
  stream . sortBy ( Person :: getName )

• groupBy - 추출기 기능별 그룹화

   // Java 8
  stream . collect ( Collectors . groupingBy ( Person :: getName )). entrySet (). stream ()
  // LSA
  stream . groupBy ( Person :: getName )

• chunkBy - 분류자 함수로 스트림을 정렬합니다.

   Stream . of ( "a" , "b" , "cd" , "ef" , "gh" , "ij" , "klmnn" )
      . chunkBy ( String :: length ) // [[a, b], [cd, ef, gh, ij], [klmnn]]

• sample - n번째 요소마다 방출합니다.

   Stream . rangeClosed ( 0 , 10 )
      . sample ( 2 ) // [0, 2, 4, 6, 8, 10]

• slidingWindow - 파티션이 고정 크기 목록으로 스트리밍되고 요소 위로 슬라이딩됩니다.

   Stream . rangeClosed ( 0 , 10 )
      . slidingWindow ( 4 , 6 ) // [[0, 1, 2, 3], [6, 7, 8, 9]]

• takeWhile / dropWhile - Java 9에 도입되었으며, 조건자 함수로 스트림을 제한/건너뜁니다.

   Stream . of ( "a" , "b" , "cd" , "ef" , "g" )
      . takeWhile ( s -> s . length () == 1 ) // [a, b]
  Stream . of ( "a" , "b" , "cd" , "ef" , "g" )
      . dropWhile ( s -> s . length () == 1 ) // [cd, ef, g]

• scan - 누적 함수를 반복적으로 적용하고 Stream을 반환합니다.

   IntStream . range ( 1 , 6 )
      . scan (( a , b ) -> a + b ) // [1, 3, 6, 10, 15]

• indexed - 모든 요소에 인덱스를 추가하고 결과는 IntPair 입니다.

   Stream . of ( "a" , "b" , "c" )
      . indexed () // [(0 : "a"), (1 : "b"), (2 : "c")]

• filterIndexed / mapIndexed / takeWhileIndexed / takeUntilIndexed / dropWhileIndexed / reduceIndexed / forEachIndexed - 연산자의 인덱스 전문화

   Stream . of ( "a" , "b" , "c" )
      . mapIndexed (( i , s ) -> s + Integer . toString ( i )) // [a0, b1, c2]

던질 수 있는 함수

더 이상 람다 표현식에서 추악한 try/catch가 필요하지 않습니다.

 // Java 8
stream . map ( file -> {
    try {
        return new FileInputStream ( file );
    } catch ( IOException ioe ) {
        return null ;
    }
})
// LSA
stream . map ( Function . Util . safe ( FileInputStream :: new ))

다운로드

최신 릴리스를 다운로드하거나 Maven을 통해 가져옵니다.

< dependency >
  < groupId >com.annimon</ groupId >
  < artifactId >stream</ artifactId >
  < version >1.2.2</ version >
</ dependency >

또는 Gradle:

dependencies {
  .. .
  implementation ' com.annimon:stream:1.2.2 '
  .. .
}

또는 JitPack으로 아직 출시되지 않은 최신 기능을 사용해 보세요.

Java ME 용 버전도 포함되어 있습니다. javame 지점을 확인하세요.