org.springframework.data/spring-data-commons/2.2.7.RELEASE : org/springframework/data/util/StreamUtils.class

StreamUtils
- lambda$0(CloseableIterator): void
https://www.spring.io/spring-data/spring-data-commons: Global parent pom.xml to be used by Spring Data modules (Pivotal Software, Inc.)
Apache License, Version 2.0
Oliver Drotbohm (Pivotal Software, Inc.)
Mark Paluch (Pivotal Software, Inc.)
public interface org.springframework.data.util.StreamUtils
  minor version: 0
  major version: 59
  flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
  this_class: org.springframework.data.util.StreamUtils
  super_class: java.lang.Object
{
  public static <T> java.util.stream.Stream<T> createStreamFromIterator(java.util.Iterator<T>);
    descriptor: (Ljava/util/Iterator;)Ljava/util/stream/Stream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.util.Iterator iterator
         0: .line 55
            aload 0 /* iterator */
            sipush 256
            invokestatic java.util.Spliterators.spliteratorUnknownSize:(Ljava/util/Iterator;I)Ljava/util/Spliterator;
            astore 1 /* spliterator */
        start local 1 // java.util.Spliterator spliterator
         1: .line 56
            aload 1 /* spliterator */
            iconst_0
            invokestatic java.util.stream.StreamSupport.stream:(Ljava/util/Spliterator;Z)Ljava/util/stream/Stream;
            areturn
        end local 1 // java.util.Spliterator spliterator
        end local 0 // java.util.Iterator iterator
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0     iterator  Ljava/util/Iterator<TT;>;
            1    2     1  spliterator  Ljava/util/Spliterator<TT;>;
    Signature: <T:Ljava/lang/Object;>(Ljava/util/Iterator<TT;>;)Ljava/util/stream/Stream<TT;>;
    MethodParameters:
          Name  Flags
      iterator  

  public static <T> java.util.stream.Stream<T> createStreamFromIterator(org.springframework.data.util.CloseableIterator<T>);
    descriptor: (Lorg/springframework/data/util/CloseableIterator;)Ljava/util/stream/Stream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.springframework.data.util.CloseableIterator iterator
         0: .line 69
            aload 0 /* iterator */
            ldc "Iterator must not be null!"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         1: .line 71
            aload 0 /* iterator */
            invokestatic org.springframework.data.util.StreamUtils.createStreamFromIterator:(Ljava/util/Iterator;)Ljava/util/stream/Stream;
            aload 0 /* iterator */
            invokedynamic run(Lorg/springframework/data/util/CloseableIterator;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  org/springframework/data/util/StreamUtils.lambda$0(Lorg/springframework/data/util/CloseableIterator;)V (6 itf)
                  ()V
            invokeinterface java.util.stream.Stream.onClose:(Ljava/lang/Runnable;)Ljava/util/stream/BaseStream;
            checkcast java.util.stream.Stream
            areturn
        end local 0 // org.springframework.data.util.CloseableIterator iterator
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0  iterator  Lorg/springframework/data/util/CloseableIterator<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lorg/springframework/data/util/CloseableIterator<TT;>;)Ljava/util/stream/Stream<TT;>;
    MethodParameters:
          Name  Flags
      iterator  

  public static <T> java.util.stream.Collector<T, ?, java.util.List<T>> toUnmodifiableList();
    descriptor: ()Ljava/util/stream/Collector;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 80
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  java/util/Collections.unmodifiableList(Ljava/util/List;)Ljava/util/List; (6)
                  (Ljava/util/List;)Ljava/util/List;
            invokestatic java.util.stream.Collectors.collectingAndThen:(Ljava/util/stream/Collector;Ljava/util/function/Function;)Ljava/util/stream/Collector;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/stream/Collector<TT;*Ljava/util/List<TT;>;>;

  public static <T> java.util.stream.Collector<T, ?, java.util.Set<T>> toUnmodifiableSet();
    descriptor: ()Ljava/util/stream/Collector;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 89
            invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  java/util/Collections.unmodifiableSet(Ljava/util/Set;)Ljava/util/Set; (6)
                  (Ljava/util/Set;)Ljava/util/Set;
            invokestatic java.util.stream.Collectors.collectingAndThen:(Ljava/util/stream/Collector;Ljava/util/function/Function;)Ljava/util/stream/Collector;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/stream/Collector<TT;*Ljava/util/Set<TT;>;>;

  public static <T, K, V> java.util.stream.Collector<T, org.springframework.util.MultiValueMap<K, V>, org.springframework.util.MultiValueMap<K, V>> toMultiMap(java.util.function.Function<T, K>, java.util.function.Function<T, V>);
    descriptor: (Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=2
         0: .line 100
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tThe method of(Function<T,K>, Function<T,V>) is undefined for the type MultiValueMapCollector\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/util/function/Function<TT;TK;>;Ljava/util/function/Function<TT;TV;>;)Ljava/util/stream/Collector<TT;Lorg/springframework/util/MultiValueMap<TK;TV;>;Lorg/springframework/util/MultiValueMap<TK;TV;>;>;
    MethodParameters:
               Name  Flags
      keyFunction    
      valueFunction  

  public static <T> java.util.stream.Stream<T> fromNullable(T);
    descriptor: (Ljava/lang/Object;)Ljava/util/stream/Stream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.lang.Object source
         0: .line 111
            aload 0 /* source */
            ifnonnull 1
            invokestatic java.util.stream.Stream.empty:()Ljava/util/stream/Stream;
            goto 2
      StackMap locals:
      StackMap stack:
         1: aload 0 /* source */
            invokestatic java.util.stream.Stream.of:(Ljava/lang/Object;)Ljava/util/stream/Stream;
      StackMap locals:
      StackMap stack: java.util.stream.Stream
         2: areturn
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0  source  TT;
    Signature: <T:Ljava/lang/Object;>(TT;)Ljava/util/stream/Stream<TT;>;
    RuntimeVisibleParameterAnnotations: 
      0:
        org.springframework.lang.Nullable()
    MethodParameters:
        Name  Flags
      source  

  public static <L, R, T> java.util.stream.Stream<T> zip(java.util.stream.Stream<L>, java.util.stream.Stream<R>, java.util.function.BiFunction<L, R, T>);
    descriptor: (Ljava/util/stream/Stream;Ljava/util/stream/Stream;Ljava/util/function/BiFunction;)Ljava/util/stream/Stream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=8, locals=9, args_size=3
        start local 0 // java.util.stream.Stream left
        start local 1 // java.util.stream.Stream right
        start local 2 // java.util.function.BiFunction combiner
         0: .line 127
            aload 0 /* left */
            ldc "Left stream must not be null!"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         1: .line 128
            aload 1 /* right */
            ldc "Right must not be null!"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         2: .line 129
            aload 2 /* combiner */
            ldc "Combiner must not be null!"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         3: .line 131
            aload 0 /* left */
            invokeinterface java.util.stream.Stream.spliterator:()Ljava/util/Spliterator;
            astore 3 /* lefts */
        start local 3 // java.util.Spliterator lefts
         4: .line 132
            aload 1 /* right */
            invokeinterface java.util.stream.Stream.spliterator:()Ljava/util/Spliterator;
            astore 4 /* rights */
        start local 4 // java.util.Spliterator rights
         5: .line 134
            aload 3 /* lefts */
            invokeinterface java.util.Spliterator.estimateSize:()J
            aload 4 /* rights */
            invokeinterface java.util.Spliterator.estimateSize:()J
            invokestatic java.lang.Long.min:(JJ)J
            lstore 5 /* size */
        start local 5 // long size
         6: .line 135
            aload 3 /* lefts */
            invokeinterface java.util.Spliterator.characteristics:()I
            aload 4 /* rights */
            invokeinterface java.util.Spliterator.characteristics:()I
            iand
            istore 7 /* characteristics */
        start local 7 // int characteristics
         7: .line 136
            aload 0 /* left */
            invokeinterface java.util.stream.Stream.isParallel:()Z
            ifne 8
            aload 1 /* right */
            invokeinterface java.util.stream.Stream.isParallel:()Z
            ifne 8
            iconst_0
            goto 9
      StackMap locals: java.util.stream.Stream java.util.stream.Stream java.util.function.BiFunction java.util.Spliterator java.util.Spliterator long int
      StackMap stack:
         8: iconst_1
      StackMap locals:
      StackMap stack: int
         9: istore 8 /* parallel */
        start local 8 // boolean parallel
        10: .line 138
            new org.springframework.data.util.StreamUtils$1
            dup
            lload 5 /* size */
            iload 7 /* characteristics */
            aload 3 /* lefts */
            aload 4 /* rights */
            aload 2 /* combiner */
            invokespecial org.springframework.data.util.StreamUtils$1.<init>:(JILjava/util/Spliterator;Ljava/util/Spliterator;Ljava/util/function/BiFunction;)V
        11: .line 146
            iload 8 /* parallel */
        12: .line 138
            invokestatic java.util.stream.StreamSupport.stream:(Ljava/util/Spliterator;Z)Ljava/util/stream/Stream;
            areturn
        end local 8 // boolean parallel
        end local 7 // int characteristics
        end local 5 // long size
        end local 4 // java.util.Spliterator rights
        end local 3 // java.util.Spliterator lefts
        end local 2 // java.util.function.BiFunction combiner
        end local 1 // java.util.stream.Stream right
        end local 0 // java.util.stream.Stream left
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   13     0             left  Ljava/util/stream/Stream<TL;>;
            0   13     1            right  Ljava/util/stream/Stream<TR;>;
            0   13     2         combiner  Ljava/util/function/BiFunction<TL;TR;TT;>;
            4   13     3            lefts  Ljava/util/Spliterator<TL;>;
            5   13     4           rights  Ljava/util/Spliterator<TR;>;
            6   13     5             size  J
            7   13     7  characteristics  I
           10   13     8         parallel  Z
    Signature: <L:Ljava/lang/Object;R:Ljava/lang/Object;T:Ljava/lang/Object;>(Ljava/util/stream/Stream<TL;>;Ljava/util/stream/Stream<TR;>;Ljava/util/function/BiFunction<TL;TR;TT;>;)Ljava/util/stream/Stream<TT;>;
    MethodParameters:
          Name  Flags
      left      
      right     
      combiner  

  private static void lambda$0(org.springframework.data.util.CloseableIterator);
    descriptor: (Lorg/springframework/data/util/CloseableIterator;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 71
            aload 0
            invokeinterface org.springframework.data.util.CloseableIterator.close:()V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
SourceFile: "StreamUtils.java"
NestMembers:
  org.springframework.data.util.StreamUtils$1
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  org.springframework.data.util.StreamUtils$1
/

org.springframework.data/ spring-data-commons/ 2.2.7.RELEASE/ org/springframework/data/util/StreamUtils.class
