test_class.file: cyclops/src/test/java/cyclops/companion/StreamsTest.java
test_class.identifier: StreamsTest
test_case.body: @Test
      public void duplicate(){
          assertThat(Streams.duplicate(Stream.of(1,2,3))._1().collect(Collectors.toList()),equalTo(Arrays.asList(1,2,3)));
          assertThat(Streams.duplicate(Stream.of())._1().collect(Collectors.toList()),equalTo(Arrays.asList()));
      }
test_case.class_method_signature: StreamsTest.duplicate()
test_case.full_signature: @Test public void duplicate()
test_case.identifier: duplicate
test_case.invocations: assertThat collect _1 duplicate of toList equalTo asList assertThat collect _1 duplicate of toList equalTo asList
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void duplicate()
focal_class.declarator: UNSET = new Object()
focal_class.modifier: private static final
focal_class.original_string: private static final Object UNSET = new Object();
focal_class.type: Object
focal_class.var_name: UNSET
focal_class.file: cyclops/src/main/java/cyclops/companion/Streams.java
focal_class.identifier: Streams
focal_class.class_method_signature: Streams.combinations(int size,Object[] a)
focal_class.full_signature: public static ReactiveSeq<ReactiveSeq<T>> combinations(int size,Object[] a)
focal_class.identifier: combinations
focal_class.modifiers: public static
focal_class.parameters: (int size,Object[] a)
focal_class.return: ReactiveSeq<ReactiveSeq<T>>
focal_class.signature: ReactiveSeq<ReactiveSeq<T>> combinations(int size,Object[] a)
focal_class.class_method_signature: Streams.permutations(Object[] a)
focal_class.full_signature: public static ReactiveSeq<ReactiveSeq<T>> permutations(Object[] a)
focal_class.identifier: permutations
focal_class.modifiers: public static
focal_class.parameters: (Object[] a)
focal_class.return: ReactiveSeq<ReactiveSeq<T>>
focal_class.signature: ReactiveSeq<ReactiveSeq<T>> permutations(Object[] a)
focal_class.class_method_signature: Streams.forEach4(Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.full_signature: public static Stream<R> forEach4(Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.identifier: forEach4
focal_class.modifiers: public static
focal_class.parameters: (Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> forEach4(Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.class_method_signature: Streams.forEach4(Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, Boolean> filterFunction,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.full_signature: public static Stream<R> forEach4(Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, Boolean> filterFunction,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.identifier: forEach4
focal_class.modifiers: public static
focal_class.parameters: (Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, Boolean> filterFunction,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> forEach4(Stream<? extends T1> value1,
                                                                   Function<? super T1, ? extends Stream<R1>> value2,
                                                                   BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                                   Function3<? super T1, ? super R1, ? super R2, ? extends Stream<R3>> value4,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, Boolean> filterFunction,
                                                                   Function4<? super T1, ? super R1, ? super R2, ? super R3, ? extends R> yieldingFunction)
focal_class.class_method_signature: Streams.forEach3(Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.full_signature: public static Stream<R> forEach3(Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.identifier: forEach3
focal_class.modifiers: public static
focal_class.parameters: (Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> forEach3(Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.class_method_signature: Streams.forEach3(Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, Boolean> filterFunction,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.full_signature: public static Stream<R> forEach3(Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, Boolean> filterFunction,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.identifier: forEach3
focal_class.modifiers: public static
focal_class.parameters: (Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, Boolean> filterFunction,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> forEach3(Stream<? extends T1> value1,
                                                           Function<? super T1, ? extends Stream<R1>> value2,
                                                           BiFunction<? super T1, ? super R1, ? extends Stream<R2>> value3,
                                                           Function3<? super T1, ? super R1, ? super R2, Boolean> filterFunction,
                                                           Function3<? super T1, ? super R1, ? super R2, ? extends R> yieldingFunction)
focal_class.class_method_signature: Streams.forEach2(Stream<? extends T> value1,
                                                 Function<? super T, Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.full_signature: public static Stream<R> forEach2(Stream<? extends T> value1,
                                                 Function<? super T, Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.identifier: forEach2
focal_class.modifiers: public static
focal_class.parameters: (Stream<? extends T> value1,
                                                 Function<? super T, Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> forEach2(Stream<? extends T> value1,
                                                 Function<? super T, Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.class_method_signature: Streams.forEach2(Stream<? extends T> value1,
                                                 Function<? super T, ? extends Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, Boolean> filterFunction,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.full_signature: public static Stream<R> forEach2(Stream<? extends T> value1,
                                                 Function<? super T, ? extends Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, Boolean> filterFunction,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.identifier: forEach2
focal_class.modifiers: public static
focal_class.parameters: (Stream<? extends T> value1,
                                                 Function<? super T, ? extends Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, Boolean> filterFunction,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> forEach2(Stream<? extends T> value1,
                                                 Function<? super T, ? extends Stream<R1>> value2,
                                                 BiFunction<? super T, ? super R1, Boolean> filterFunction,
                                                 BiFunction<? super T, ? super R1, ? extends R> yieldingFunction)
focal_class.class_method_signature: Streams.streamToOptional(final Stream<T> stream)
focal_class.full_signature: public final static Optional<Seq<T>> streamToOptional(final Stream<T> stream)
focal_class.identifier: streamToOptional
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Optional<Seq<T>>
focal_class.signature: Optional<Seq<T>> streamToOptional(final Stream<T> stream)
focal_class.class_method_signature: Streams.optionalToStream(final Optional<T> optional)
focal_class.full_signature: public final static Stream<T> optionalToStream(final Optional<T> optional)
focal_class.identifier: optionalToStream
focal_class.modifiers: public final static
focal_class.parameters: (final Optional<T> optional)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> optionalToStream(final Optional<T> optional)
focal_class.class_method_signature: Streams.streamToCompletableFuture(final Stream<T> stream)
focal_class.full_signature: public final static CompletableFuture<List<T>> streamToCompletableFuture(final Stream<T> stream)
focal_class.identifier: streamToCompletableFuture
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: CompletableFuture<List<T>>
focal_class.signature: CompletableFuture<List<T>> streamToCompletableFuture(final Stream<T> stream)
focal_class.class_method_signature: Streams.completableFutureToStream(final CompletableFuture<T> future)
focal_class.full_signature: public final static Stream<T> completableFutureToStream(final CompletableFuture<T> future)
focal_class.identifier: completableFutureToStream
focal_class.modifiers: public final static
focal_class.parameters: (final CompletableFuture<T> future)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> completableFutureToStream(final CompletableFuture<T> future)
focal_class.class_method_signature: Streams.forEach(final Stream<T> stream, final long x, final Consumer<? super T> consumerElement)
focal_class.full_signature: public static Subscription forEach(final Stream<T> stream, final long x, final Consumer<? super T> consumerElement)
focal_class.identifier: forEach
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final long x, final Consumer<? super T> consumerElement)
focal_class.return: Subscription
focal_class.signature: Subscription forEach(final Stream<T> stream, final long x, final Consumer<? super T> consumerElement)
focal_class.class_method_signature: Streams.forEach(final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError)
focal_class.full_signature: public static Subscription forEach(final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError)
focal_class.identifier: forEach
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError)
focal_class.return: Subscription
focal_class.signature: Subscription forEach(final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError)
focal_class.class_method_signature: Streams.forEach(final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.full_signature: public static Subscription forEach(final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.identifier: forEach
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.return: Subscription
focal_class.signature: Subscription forEach(final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.class_method_signature: Streams.forEach(final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError)
focal_class.full_signature: public static void forEach(final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError)
focal_class.identifier: forEach
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError)
focal_class.return: void
focal_class.signature: void forEach(final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError)
focal_class.class_method_signature: Streams.forEach(final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.full_signature: public static void forEach(final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.identifier: forEach
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.return: void
focal_class.signature: void forEach(final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError, final Runnable onComplete)
focal_class.class_method_signature: Streams.schedule(final Stream<T> stream, final String cron, final ScheduledExecutorService ex)
focal_class.full_signature: public static Connectable<T> schedule(final Stream<T> stream, final String cron, final ScheduledExecutorService ex)
focal_class.identifier: schedule
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final String cron, final ScheduledExecutorService ex)
focal_class.return: Connectable<T>
focal_class.signature: Connectable<T> schedule(final Stream<T> stream, final String cron, final ScheduledExecutorService ex)
focal_class.class_method_signature: Streams.scheduleFixedDelay(final Stream<T> stream, final long delay, final ScheduledExecutorService ex)
focal_class.full_signature: public static Connectable<T> scheduleFixedDelay(final Stream<T> stream, final long delay, final ScheduledExecutorService ex)
focal_class.identifier: scheduleFixedDelay
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final long delay, final ScheduledExecutorService ex)
focal_class.return: Connectable<T>
focal_class.signature: Connectable<T> scheduleFixedDelay(final Stream<T> stream, final long delay, final ScheduledExecutorService ex)
focal_class.class_method_signature: Streams.scheduleFixedRate(final Stream<T> stream, final long rate, final ScheduledExecutorService ex)
focal_class.full_signature: public static Connectable<T> scheduleFixedRate(final Stream<T> stream, final long rate, final ScheduledExecutorService ex)
focal_class.identifier: scheduleFixedRate
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final long rate, final ScheduledExecutorService ex)
focal_class.return: Connectable<T>
focal_class.signature: Connectable<T> scheduleFixedRate(final Stream<T> stream, final long rate, final ScheduledExecutorService ex)
focal_class.class_method_signature: Streams.splitAt(final Stream<T> stream, final int where)
focal_class.full_signature: public final static Tuple2<Stream<T>, Stream<T>> splitAt(final Stream<T> stream, final int where)
focal_class.identifier: splitAt
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int where)
focal_class.return: Tuple2<Stream<T>, Stream<T>>
focal_class.signature: Tuple2<Stream<T>, Stream<T>> splitAt(final Stream<T> stream, final int where)
focal_class.class_method_signature: Streams.splitBy(final Stream<T> stream, final Predicate<T> splitter)
focal_class.full_signature: public final static Tuple2<Stream<T>, Stream<T>> splitBy(final Stream<T> stream, final Predicate<T> splitter)
focal_class.identifier: splitBy
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<T> splitter)
focal_class.return: Tuple2<Stream<T>, Stream<T>>
focal_class.signature: Tuple2<Stream<T>, Stream<T>> splitBy(final Stream<T> stream, final Predicate<T> splitter)
focal_class.class_method_signature: Streams.partition(final Stream<T> stream, final Predicate<? super T> splitter)
focal_class.full_signature: public final static Tuple2<Stream<T>, Stream<T>> partition(final Stream<T> stream, final Predicate<? super T> splitter)
focal_class.identifier: partition
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> splitter)
focal_class.return: Tuple2<Stream<T>, Stream<T>>
focal_class.signature: Tuple2<Stream<T>, Stream<T>> partition(final Stream<T> stream, final Predicate<? super T> splitter)
focal_class.class_method_signature: Streams.duplicate(final Stream<T> stream)
focal_class.full_signature: public final static Tuple2<Stream<T>, Stream<T>> duplicate(final Stream<T> stream)
focal_class.identifier: duplicate
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Tuple2<Stream<T>, Stream<T>>
focal_class.signature: Tuple2<Stream<T>, Stream<T>> duplicate(final Stream<T> stream)
focal_class.class_method_signature: Streams.duplicate(final Stream<T> stream,Supplier<Deque<T>> bufferFactory)
focal_class.full_signature: public final static Tuple2<Stream<T>, Stream<T>> duplicate(final Stream<T> stream,Supplier<Deque<T>> bufferFactory)
focal_class.identifier: duplicate
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream,Supplier<Deque<T>> bufferFactory)
focal_class.return: Tuple2<Stream<T>, Stream<T>>
focal_class.signature: Tuple2<Stream<T>, Stream<T>> duplicate(final Stream<T> stream,Supplier<Deque<T>> bufferFactory)
focal_class.class_method_signature: Streams.duplicatePos(final Stream<T> stream, final int pos)
focal_class.full_signature: private final static Tuple2<Stream<T>, Stream<T>> duplicatePos(final Stream<T> stream, final int pos)
focal_class.identifier: duplicatePos
focal_class.modifiers: private final static
focal_class.parameters: (final Stream<T> stream, final int pos)
focal_class.return: Tuple2<Stream<T>, Stream<T>>
focal_class.signature: Tuple2<Stream<T>, Stream<T>> duplicatePos(final Stream<T> stream, final int pos)
focal_class.class_method_signature: Streams.triplicate(final Stream<T> stream)
focal_class.full_signature: @SuppressWarnings("unchecked") public final static Tuple3<Stream<T>, Stream<T>, Stream<T>> triplicate(final Stream<T> stream)
focal_class.identifier: triplicate
focal_class.modifiers: @SuppressWarnings("unchecked") public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Tuple3<Stream<T>, Stream<T>, Stream<T>>
focal_class.signature: Tuple3<Stream<T>, Stream<T>, Stream<T>> triplicate(final Stream<T> stream)
focal_class.class_method_signature: Streams.triplicate(final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.full_signature: @SuppressWarnings("unchecked") public final static Tuple3<Stream<T>, Stream<T>, Stream<T>> triplicate(final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.identifier: triplicate
focal_class.modifiers: @SuppressWarnings("unchecked") public final static
focal_class.parameters: (final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.return: Tuple3<Stream<T>, Stream<T>, Stream<T>>
focal_class.signature: Tuple3<Stream<T>, Stream<T>, Stream<T>> triplicate(final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.class_method_signature: Streams.quadruplicate(final Stream<T> stream)
focal_class.full_signature: @SuppressWarnings("unchecked") public final static Tuple4<Stream<T>, Stream<T>, Stream<T>, Stream<T>> quadruplicate(final Stream<T> stream)
focal_class.identifier: quadruplicate
focal_class.modifiers: @SuppressWarnings("unchecked") public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Tuple4<Stream<T>, Stream<T>, Stream<T>, Stream<T>>
focal_class.signature: Tuple4<Stream<T>, Stream<T>, Stream<T>, Stream<T>> quadruplicate(final Stream<T> stream)
focal_class.class_method_signature: Streams.quadruplicate(final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.full_signature: @SuppressWarnings("unchecked") public final static Tuple4<Stream<T>, Stream<T>, Stream<T>, Stream<T>> quadruplicate(final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.identifier: quadruplicate
focal_class.modifiers: @SuppressWarnings("unchecked") public final static
focal_class.parameters: (final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.return: Tuple4<Stream<T>, Stream<T>, Stream<T>, Stream<T>>
focal_class.signature: Tuple4<Stream<T>, Stream<T>, Stream<T>, Stream<T>> quadruplicate(final Stream<T> stream, Supplier<Deque<T>> bufferFactory)
focal_class.class_method_signature: Streams.appendStream(final Stream<T> stream1, final Stream<T> append)
focal_class.full_signature: public static final Stream<T> appendStream(final Stream<T> stream1, final Stream<T> append)
focal_class.identifier: appendStream
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<T> stream1, final Stream<T> append)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> appendStream(final Stream<T> stream1, final Stream<T> append)
focal_class.class_method_signature: Streams.prependStream(final Stream<T> stream1, final Stream<T> prepend)
focal_class.full_signature: public static final Stream<T> prependStream(final Stream<T> stream1, final Stream<T> prepend)
focal_class.identifier: prependStream
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<T> stream1, final Stream<T> prepend)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> prependStream(final Stream<T> stream1, final Stream<T> prepend)
focal_class.class_method_signature: Streams.append(final Stream<T> stream, final T... values)
focal_class.full_signature: public static final Stream<T> append(final Stream<T> stream, final T... values)
focal_class.identifier: append
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<T> stream, final T... values)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> append(final Stream<T> stream, final T... values)
focal_class.class_method_signature: Streams.prepend(final Stream<T> stream, final T... values)
focal_class.full_signature: public static final Stream<T> prepend(final Stream<T> stream, final T... values)
focal_class.identifier: prepend
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<T> stream, final T... values)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> prepend(final Stream<T> stream, final T... values)
focal_class.class_method_signature: Streams.insertAt(final Stream<T> stream, final int pos, final T... values)
focal_class.full_signature: public static final Stream<T> insertAt(final Stream<T> stream, final int pos, final T... values)
focal_class.identifier: insertAt
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<T> stream, final int pos, final T... values)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> insertAt(final Stream<T> stream, final int pos, final T... values)
focal_class.class_method_signature: Streams.deleteBetween(final Stream<T> stream, final int start, final int end)
focal_class.full_signature: public static final Stream<T> deleteBetween(final Stream<T> stream, final int start, final int end)
focal_class.identifier: deleteBetween
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<T> stream, final int start, final int end)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> deleteBetween(final Stream<T> stream, final int start, final int end)
focal_class.class_method_signature: Streams.insertStreamAt(final Stream<T> stream1, final int pos, final Stream<T> insert)
focal_class.full_signature: public static final Stream<T> insertStreamAt(final Stream<T> stream1, final int pos, final Stream<T> insert)
focal_class.identifier: insertStreamAt
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<T> stream1, final int pos, final Stream<T> insert)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> insertStreamAt(final Stream<T> stream1, final int pos, final Stream<T> insert)
focal_class.class_method_signature: Streams.dropUntil(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.full_signature: public static Stream<U> dropUntil(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.identifier: dropUntil
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> dropUntil(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.class_method_signature: Streams.dropRight(final Stream<U> stream, final int num)
focal_class.full_signature: public static Stream<U> dropRight(final Stream<U> stream, final int num)
focal_class.identifier: dropRight
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final int num)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> dropRight(final Stream<U> stream, final int num)
focal_class.class_method_signature: Streams.takeRight(final Stream<U> stream, final int num)
focal_class.full_signature: public static Stream<U> takeRight(final Stream<U> stream, final int num)
focal_class.identifier: takeRight
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final int num)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> takeRight(final Stream<U> stream, final int num)
focal_class.class_method_signature: Streams.recover(final Stream<T> stream, final Function<Throwable, ? extends T> fn)
focal_class.full_signature: public static Stream<T> recover(final Stream<T> stream, final Function<Throwable, ? extends T> fn)
focal_class.identifier: recover
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final Function<Throwable, ? extends T> fn)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> recover(final Stream<T> stream, final Function<Throwable, ? extends T> fn)
focal_class.class_method_signature: Streams.recover(final Stream<T> stream, final Class<EX> type, final Function<EX, ? extends T> fn)
focal_class.full_signature: public static Stream<T> recover(final Stream<T> stream, final Class<EX> type, final Function<EX, ? extends T> fn)
focal_class.identifier: recover
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final Class<EX> type, final Function<EX, ? extends T> fn)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> recover(final Stream<T> stream, final Class<EX> type, final Function<EX, ? extends T> fn)
focal_class.class_method_signature: Streams.dropWhile(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.full_signature: public static Stream<U> dropWhile(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.identifier: dropWhile
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> dropWhile(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.class_method_signature: Streams.take(final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.full_signature: public static Stream<U> take(final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.identifier: take
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> take(final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.class_method_signature: Streams.drop(final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.full_signature: public static Stream<U> drop(final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.identifier: drop
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> drop(final Stream<U> stream, final long time, final TimeUnit unit)
focal_class.class_method_signature: Streams.combine(final Stream<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.full_signature: public static Stream<T> combine(final Stream<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.identifier: combine
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> combine(final Stream<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.class_method_signature: Streams.combineI(final Iterable<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.full_signature: public static Iterable<Iterable<T>> combineI(final Iterable<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.identifier: combineI
focal_class.modifiers: public static
focal_class.parameters: (final Iterable<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.return: Iterable<Iterable<T>>
focal_class.signature: Iterable<Iterable<T>> combineI(final Iterable<T> stream, final BiPredicate<? super T, ? super T> predicate, final BinaryOperator<T> op)
focal_class.class_method_signature: Streams.takeWhile(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.full_signature: public static Stream<U> takeWhile(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.identifier: takeWhile
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> takeWhile(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.class_method_signature: Streams.takeUntil(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.full_signature: public static Stream<U> takeUntil(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.identifier: takeUntil
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> takeUntil(final Stream<U> stream, final Predicate<? super U> predicate)
focal_class.class_method_signature: Streams.reverse(final Stream<U> stream)
focal_class.full_signature: public static Stream<U> reverse(final Stream<U> stream)
focal_class.identifier: reverse
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> stream)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> reverse(final Stream<U> stream)
focal_class.class_method_signature: Streams.reversedStream(final List<U> list)
focal_class.full_signature: public static Stream<U> reversedStream(final List<U> list)
focal_class.identifier: reversedStream
focal_class.modifiers: public static
focal_class.parameters: (final List<U> list)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> reversedStream(final List<U> list)
focal_class.class_method_signature: Streams.cycle(final Stream<U> s)
focal_class.full_signature: public static Stream<U> cycle(final Stream<U> s)
focal_class.identifier: cycle
focal_class.modifiers: public static
focal_class.parameters: (final Stream<U> s)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> cycle(final Stream<U> s)
focal_class.class_method_signature: Streams.cycle(final Streamable<U> s)
focal_class.full_signature: public static Stream<U> cycle(final Streamable<U> s)
focal_class.identifier: cycle
focal_class.modifiers: public static
focal_class.parameters: (final Streamable<U> s)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> cycle(final Streamable<U> s)
focal_class.class_method_signature: Streams.cycle(final long times, final Streamable<U> s)
focal_class.full_signature: public static Stream<U> cycle(final long times, final Streamable<U> s)
focal_class.identifier: cycle
focal_class.modifiers: public static
focal_class.parameters: (final long times, final Streamable<U> s)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> cycle(final long times, final Streamable<U> s)
focal_class.class_method_signature: Streams.stream(final Iterable<U> it)
focal_class.full_signature: public static Stream<U> stream(final Iterable<U> it)
focal_class.identifier: stream
focal_class.modifiers: public static
focal_class.parameters: (final Iterable<U> it)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> stream(final Iterable<U> it)
focal_class.class_method_signature: Streams.stream(final Spliterator<U> it)
focal_class.full_signature: public static Stream<U> stream(final Spliterator<U> it)
focal_class.identifier: stream
focal_class.modifiers: public static
focal_class.parameters: (final Spliterator<U> it)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> stream(final Spliterator<U> it)
focal_class.class_method_signature: Streams.stream(final Iterator<U> it)
focal_class.full_signature: public static Stream<U> stream(final Iterator<U> it)
focal_class.identifier: stream
focal_class.modifiers: public static
focal_class.parameters: (final Iterator<U> it)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> stream(final Iterator<U> it)
focal_class.class_method_signature: Streams.concat(final Object o, final Stream<U> stream)
focal_class.full_signature: @Deprecated public static Stream<U> concat(final Object o, final Stream<U> stream)
focal_class.identifier: concat
focal_class.modifiers: @Deprecated public static
focal_class.parameters: (final Object o, final Stream<U> stream)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> concat(final Object o, final Stream<U> stream)
focal_class.class_method_signature: Streams.stream(final Map<K, V> it)
focal_class.full_signature: public final static Stream<Map.Entry<K, V>> stream(final Map<K, V> it)
focal_class.identifier: stream
focal_class.modifiers: public final static
focal_class.parameters: (final Map<K, V> it)
focal_class.return: Stream<Map.Entry<K, V>>
focal_class.signature: Stream<Map.Entry<K, V>> stream(final Map<K, V> it)
focal_class.class_method_signature: Streams.firstValue(final Stream<T> stream)
focal_class.full_signature: public final static T firstValue(final Stream<T> stream)
focal_class.identifier: firstValue
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: T
focal_class.signature: T firstValue(final Stream<T> stream)
focal_class.class_method_signature: Streams.reduce(final Stream<R> stream, final Iterable<? extends Monoid<R>> reducers)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) public static Seq<R> reduce(final Stream<R> stream, final Iterable<? extends Monoid<R>> reducers)
focal_class.identifier: reduce
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) public static
focal_class.parameters: (final Stream<R> stream, final Iterable<? extends Monoid<R>> reducers)
focal_class.return: Seq<R>
focal_class.signature: Seq<R> reduce(final Stream<R> stream, final Iterable<? extends Monoid<R>> reducers)
focal_class.class_method_signature: Streams.reduce(final Stream<R> stream, final Stream<? extends Monoid<R>> reducers)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) public static Seq<R> reduce(final Stream<R> stream, final Stream<? extends Monoid<R>> reducers)
focal_class.identifier: reduce
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) public static
focal_class.parameters: (final Stream<R> stream, final Stream<? extends Monoid<R>> reducers)
focal_class.return: Seq<R>
focal_class.signature: Seq<R> reduce(final Stream<R> stream, final Stream<? extends Monoid<R>> reducers)
focal_class.class_method_signature: Streams.cycleWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.full_signature: public final static Stream<T> cycleWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.identifier: cycleWhile
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> cycleWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.class_method_signature: Streams.cycleUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.full_signature: public final static Stream<T> cycleUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.identifier: cycleUntil
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> cycleUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.class_method_signature: Streams.zipSequence(final Stream<T> stream, final Stream<? extends S> second,
              final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.full_signature: public final static Stream<R> zipSequence(final Stream<T> stream, final Stream<? extends S> second,
              final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.identifier: zipSequence
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Stream<? extends S> second,
              final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> zipSequence(final Stream<T> stream, final Stream<? extends S> second,
              final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.class_method_signature: Streams.zipStream(final Stream<T> stream,
              final BaseStream<? extends S, ? extends BaseStream<? extends S, ?>> second, final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.full_signature: public final static Stream<R> zipStream(final Stream<T> stream,
              final BaseStream<? extends S, ? extends BaseStream<? extends S, ?>> second, final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.identifier: zipStream
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream,
              final BaseStream<? extends S, ? extends BaseStream<? extends S, ?>> second, final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> zipStream(final Stream<T> stream,
              final BaseStream<? extends S, ? extends BaseStream<? extends S, ?>> second, final BiFunction<? super T, ? super S, ? extends R> zipper)
focal_class.class_method_signature: Streams.sliding(final Stream<T> stream, final int windowSize, final int increment)
focal_class.full_signature: public final static Stream<Seq<T>> sliding(final Stream<T> stream, final int windowSize, final int increment)
focal_class.identifier: sliding
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int windowSize, final int increment)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> sliding(final Stream<T> stream, final int windowSize, final int increment)
focal_class.class_method_signature: Streams.window(final Stream<T> stream, final int windowSize, final int increment)
focal_class.full_signature: public final static Stream<Streamable<T>> window(final Stream<T> stream, final int windowSize, final int increment)
focal_class.identifier: window
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int windowSize, final int increment)
focal_class.return: Stream<Streamable<T>>
focal_class.signature: Stream<Streamable<T>> window(final Stream<T> stream, final int windowSize, final int increment)
focal_class.class_method_signature: Streams.sliding(final Stream<T> stream, final int windowSize)
focal_class.full_signature: public final static Stream<Seq<T>> sliding(final Stream<T> stream, final int windowSize)
focal_class.identifier: sliding
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int windowSize)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> sliding(final Stream<T> stream, final int windowSize)
focal_class.class_method_signature: Streams.grouped(final Stream<T> stream, final int groupSize)
focal_class.full_signature: public final static Stream<Vector<T>> grouped(final Stream<T> stream, final int groupSize)
focal_class.identifier: grouped
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int groupSize)
focal_class.return: Stream<Vector<T>>
focal_class.signature: Stream<Vector<T>> grouped(final Stream<T> stream, final int groupSize)
focal_class.class_method_signature: Streams.grouped(final Stream<T> stream, final int groupSize,
              final Supplier<C> factory)
focal_class.full_signature: public final static Stream<C> grouped(final Stream<T> stream, final int groupSize,
              final Supplier<C> factory)
focal_class.identifier: grouped
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int groupSize,
              final Supplier<C> factory)
focal_class.return: Stream<C>
focal_class.signature: Stream<C> grouped(final Stream<T> stream, final int groupSize,
              final Supplier<C> factory)
focal_class.class_method_signature: Streams.shuffle(final Stream<T> stream)
focal_class.full_signature: public final static Streamable<T> shuffle(final Stream<T> stream)
focal_class.identifier: shuffle
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Streamable<T>
focal_class.signature: Streamable<T> shuffle(final Stream<T> stream)
focal_class.class_method_signature: Streams.toLazyStreamable(final Stream<T> stream)
focal_class.full_signature: public final static Streamable<T> toLazyStreamable(final Stream<T> stream)
focal_class.identifier: toLazyStreamable
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Streamable<T>
focal_class.signature: Streamable<T> toLazyStreamable(final Stream<T> stream)
focal_class.class_method_signature: Streams.scanRight(final Stream<T> stream, final U identity,
              final BiFunction<? super T, ? super U, ? extends U> combiner)
focal_class.full_signature: public final static Stream<U> scanRight(final Stream<T> stream, final U identity,
              final BiFunction<? super T, ? super U, ? extends U> combiner)
focal_class.identifier: scanRight
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final U identity,
              final BiFunction<? super T, ? super U, ? extends U> combiner)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> scanRight(final Stream<T> stream, final U identity,
              final BiFunction<? super T, ? super U, ? extends U> combiner)
focal_class.class_method_signature: Streams.scanLeft(final Stream<T> stream, final Monoid<T> monoid)
focal_class.full_signature: public final static Stream<T> scanLeft(final Stream<T> stream, final Monoid<T> monoid)
focal_class.identifier: scanLeft
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Monoid<T> monoid)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> scanLeft(final Stream<T> stream, final Monoid<T> monoid)
focal_class.class_method_signature: Streams.xMatch(final Stream<T> stream, final int num, final Predicate<? super T> c)
focal_class.full_signature: public static boolean xMatch(final Stream<T> stream, final int num, final Predicate<? super T> c)
focal_class.identifier: xMatch
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final int num, final Predicate<? super T> c)
focal_class.return: boolean
focal_class.signature: boolean xMatch(final Stream<T> stream, final int num, final Predicate<? super T> c)
focal_class.class_method_signature: Streams.noneMatch(final Stream<T> stream, final Predicate<? super T> c)
focal_class.full_signature: public final static boolean noneMatch(final Stream<T> stream, final Predicate<? super T> c)
focal_class.identifier: noneMatch
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> c)
focal_class.return: boolean
focal_class.signature: boolean noneMatch(final Stream<T> stream, final Predicate<? super T> c)
focal_class.class_method_signature: Streams.join(final Stream<T> stream)
focal_class.full_signature: public final static String join(final Stream<T> stream)
focal_class.identifier: join
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: String
focal_class.signature: String join(final Stream<T> stream)
focal_class.class_method_signature: Streams.join(final Stream<T> stream, final String sep)
focal_class.full_signature: public final static String join(final Stream<T> stream, final String sep)
focal_class.identifier: join
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final String sep)
focal_class.return: String
focal_class.signature: String join(final Stream<T> stream, final String sep)
focal_class.class_method_signature: Streams.join(final Stream<T> stream, final String sep, final String start, final String end)
focal_class.full_signature: public final static String join(final Stream<T> stream, final String sep, final String start, final String end)
focal_class.identifier: join
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final String sep, final String start, final String end)
focal_class.return: String
focal_class.signature: String join(final Stream<T> stream, final String sep, final String start, final String end)
focal_class.class_method_signature: Streams.minBy(final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.full_signature: public final static Optional<T> minBy(final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.identifier: minBy
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.return: Optional<T>
focal_class.signature: Optional<T> minBy(final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.class_method_signature: Streams.min(final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.full_signature: public final static Optional<T> min(final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.identifier: min
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.return: Optional<T>
focal_class.signature: Optional<T> min(final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.class_method_signature: Streams.maxBy(final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.full_signature: public final static Optional<T> maxBy(final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.identifier: maxBy
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.return: Optional<T>
focal_class.signature: Optional<T> maxBy(final Stream<T> stream, final Function<? super T, ? extends C> f)
focal_class.class_method_signature: Streams.max(final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.full_signature: public final static Optional<T> max(final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.identifier: max
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.return: Optional<T>
focal_class.signature: Optional<T> max(final Stream<T> stream, final Comparator<? super T> comparator)
focal_class.class_method_signature: Streams.foldMap(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.full_signature: public final static R foldMap(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.identifier: foldMap
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.return: R
focal_class.signature: R foldMap(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.class_method_signature: Streams.foldMap(final Stream<T> stream, final Function<? super T, ? extends R> mapper, final Monoid<R> reducer)
focal_class.full_signature: public final static R foldMap(final Stream<T> stream, final Function<? super T, ? extends R> mapper, final Monoid<R> reducer)
focal_class.identifier: foldMap
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, ? extends R> mapper, final Monoid<R> reducer)
focal_class.return: R
focal_class.signature: R foldMap(final Stream<T> stream, final Function<? super T, ? extends R> mapper, final Monoid<R> reducer)
focal_class.class_method_signature: Streams.foldLeft(final Stream<T> stream, final Monoid<T> reducer)
focal_class.full_signature: public final static T foldLeft(final Stream<T> stream, final Monoid<T> reducer)
focal_class.identifier: foldLeft
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Monoid<T> reducer)
focal_class.return: T
focal_class.signature: T foldLeft(final Stream<T> stream, final Monoid<T> reducer)
focal_class.class_method_signature: Streams.foldLeftMapToType(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.full_signature: public final static R foldLeftMapToType(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.identifier: foldLeftMapToType
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.return: R
focal_class.signature: R foldLeftMapToType(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.class_method_signature: Streams.foldRight(final Stream<T> stream, final Monoid<T> reducer)
focal_class.full_signature: public final static T foldRight(final Stream<T> stream, final Monoid<T> reducer)
focal_class.identifier: foldRight
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Monoid<T> reducer)
focal_class.return: T
focal_class.signature: T foldRight(final Stream<T> stream, final Monoid<T> reducer)
focal_class.class_method_signature: Streams.foldRightMapToType(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.full_signature: public final static R foldRightMapToType(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.identifier: foldRightMapToType
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.return: R
focal_class.signature: R foldRightMapToType(final Stream<T> stream, final Reducer<R,T> reducer)
focal_class.class_method_signature: Streams.toStreamable(final Stream<T> stream)
focal_class.full_signature: public final static Streamable<T> toStreamable(final Stream<T> stream)
focal_class.identifier: toStreamable
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Streamable<T>
focal_class.signature: Streamable<T> toStreamable(final Stream<T> stream)
focal_class.class_method_signature: Streams.toSet(final Stream<T> stream)
focal_class.full_signature: public final static Set<T> toSet(final Stream<T> stream)
focal_class.identifier: toSet
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: Set<T>
focal_class.signature: Set<T> toSet(final Stream<T> stream)
focal_class.class_method_signature: Streams.toList(final Stream<T> stream)
focal_class.full_signature: public final static List<T> toList(final Stream<T> stream)
focal_class.identifier: toList
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: List<T>
focal_class.signature: List<T> toList(final Stream<T> stream)
focal_class.class_method_signature: Streams.startsWith(final Stream<T> stream, final Iterable<T> iterable)
focal_class.full_signature: public final static boolean startsWith(final Stream<T> stream, final Iterable<T> iterable)
focal_class.identifier: startsWith
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Iterable<T> iterable)
focal_class.return: boolean
focal_class.signature: boolean startsWith(final Stream<T> stream, final Iterable<T> iterable)
focal_class.class_method_signature: Streams.findSize(Iterable<T> iterable)
focal_class.full_signature: private static Tuple2<Integer,Iterator<T>> findSize(Iterable<T> iterable)
focal_class.identifier: findSize
focal_class.modifiers: private static
focal_class.parameters: (Iterable<T> iterable)
focal_class.return: Tuple2<Integer,Iterator<T>>
focal_class.signature: Tuple2<Integer,Iterator<T>> findSize(Iterable<T> iterable)
focal_class.class_method_signature: Streams.endsWith(final Stream<T> stream, final Iterable<T> iterable)
focal_class.full_signature: public final static boolean endsWith(final Stream<T> stream, final Iterable<T> iterable)
focal_class.identifier: endsWith
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Iterable<T> iterable)
focal_class.return: boolean
focal_class.signature: boolean endsWith(final Stream<T> stream, final Iterable<T> iterable)
focal_class.class_method_signature: Streams.startsWith(final Stream<T> stream, final Stream<T> stream2)
focal_class.full_signature: public final static boolean startsWith(final Stream<T> stream, final Stream<T> stream2)
focal_class.identifier: startsWith
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Stream<T> stream2)
focal_class.return: boolean
focal_class.signature: boolean startsWith(final Stream<T> stream, final Stream<T> stream2)
focal_class.class_method_signature: Streams.startsWith(final Stream<T> stream, final Iterator<T> iterator)
focal_class.full_signature: public final static boolean startsWith(final Stream<T> stream, final Iterator<T> iterator)
focal_class.identifier: startsWith
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Iterator<T> iterator)
focal_class.return: boolean
focal_class.signature: boolean startsWith(final Stream<T> stream, final Iterator<T> iterator)
focal_class.class_method_signature: Streams.oneShotStream(final Iterable<T> iterable)
focal_class.full_signature: public static ReactiveSeq<T> oneShotStream(final Iterable<T> iterable)
focal_class.identifier: oneShotStream
focal_class.modifiers: public static
focal_class.parameters: (final Iterable<T> iterable)
focal_class.return: ReactiveSeq<T>
focal_class.signature: ReactiveSeq<T> oneShotStream(final Iterable<T> iterable)
focal_class.class_method_signature: Streams.oneShotStream(Stream<T> stream)
focal_class.full_signature: public static ReactiveSeq<T> oneShotStream(Stream<T> stream)
focal_class.identifier: oneShotStream
focal_class.modifiers: public static
focal_class.parameters: (Stream<T> stream)
focal_class.return: ReactiveSeq<T>
focal_class.signature: ReactiveSeq<T> oneShotStream(Stream<T> stream)
focal_class.class_method_signature: Streams.oneShotStream(Spliterator<T> stream,final Optional<ReversableSpliterator> rev)
focal_class.full_signature: public static OneShotStreamX<T> oneShotStream(Spliterator<T> stream,final Optional<ReversableSpliterator> rev)
focal_class.identifier: oneShotStream
focal_class.modifiers: public static
focal_class.parameters: (Spliterator<T> stream,final Optional<ReversableSpliterator> rev)
focal_class.return: OneShotStreamX<T>
focal_class.signature: OneShotStreamX<T> oneShotStream(Spliterator<T> stream,final Optional<ReversableSpliterator> rev)
focal_class.class_method_signature: Streams.reactiveSeq(final Stream<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.full_signature: public final static ReactiveSeq<T> reactiveSeq(final Stream<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.identifier: reactiveSeq
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.return: ReactiveSeq<T>
focal_class.signature: ReactiveSeq<T> reactiveSeq(final Stream<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.class_method_signature: Streams.reactiveSeq(final Iterable<T> iterable)
focal_class.full_signature: public final static ReactiveSeq<T> reactiveSeq(final Iterable<T> iterable)
focal_class.identifier: reactiveSeq
focal_class.modifiers: public final static
focal_class.parameters: (final Iterable<T> iterable)
focal_class.return: ReactiveSeq<T>
focal_class.signature: ReactiveSeq<T> reactiveSeq(final Iterable<T> iterable)
focal_class.class_method_signature: Streams.reactiveSeq(final Stream<T> stream)
focal_class.full_signature: public final static ReactiveSeq<T> reactiveSeq(final Stream<T> stream)
focal_class.identifier: reactiveSeq
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream)
focal_class.return: ReactiveSeq<T>
focal_class.signature: ReactiveSeq<T> reactiveSeq(final Stream<T> stream)
focal_class.class_method_signature: Streams.reactiveSeq(final Spliterator<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.full_signature: public final static ReactiveSeq<T> reactiveSeq(final Spliterator<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.identifier: reactiveSeq
focal_class.modifiers: public final static
focal_class.parameters: (final Spliterator<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.return: ReactiveSeq<T>
focal_class.signature: ReactiveSeq<T> reactiveSeq(final Spliterator<? super T> stream, final Optional<ReversableSpliterator> rev)
focal_class.class_method_signature: Streams.intersperse(final Stream<T> stream, final T value)
focal_class.full_signature: public static Stream<T> intersperse(final Stream<T> stream, final T value)
focal_class.identifier: intersperse
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final T value)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> intersperse(final Stream<T> stream, final T value)
focal_class.class_method_signature: Streams.ofType(final Stream<T> stream, final Class<? extends U> type)
focal_class.full_signature: @SuppressWarnings("unchecked") public static Stream<U> ofType(final Stream<T> stream, final Class<? extends U> type)
focal_class.identifier: ofType
focal_class.modifiers: @SuppressWarnings("unchecked") public static
focal_class.parameters: (final Stream<T> stream, final Class<? extends U> type)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> ofType(final Stream<T> stream, final Class<? extends U> type)
focal_class.class_method_signature: Streams.cast(final Stream<T> stream, final Class<? extends U> type)
focal_class.full_signature: public static Stream<U> cast(final Stream<T> stream, final Class<? extends U> type)
focal_class.identifier: cast
focal_class.modifiers: public static
focal_class.parameters: (final Stream<T> stream, final Class<? extends U> type)
focal_class.return: Stream<U>
focal_class.signature: Stream<U> cast(final Stream<T> stream, final Class<? extends U> type)
focal_class.class_method_signature: Streams.narrow(Stream<? extends T> stream)
focal_class.full_signature: public final static Stream<T> narrow(Stream<? extends T> stream)
focal_class.identifier: narrow
focal_class.modifiers: public final static
focal_class.parameters: (Stream<? extends T> stream)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> narrow(Stream<? extends T> stream)
focal_class.class_method_signature: Streams.concatMapterable(final Stream<T> stream, final Function<? super T, ? extends Iterable<? extends R>> fn)
focal_class.full_signature: public final static Stream<R> concatMapterable(final Stream<T> stream, final Function<? super T, ? extends Iterable<? extends R>> fn)
focal_class.identifier: concatMapterable
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, ? extends Iterable<? extends R>> fn)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> concatMapterable(final Stream<T> stream, final Function<? super T, ? extends Iterable<? extends R>> fn)
focal_class.class_method_signature: Streams.flatMapStream(final Stream<T> stream, final Function<? super T, ? extends BaseStream<? extends R, ?>> fn)
focal_class.full_signature: public final static Stream<R> flatMapStream(final Stream<T> stream, final Function<? super T, ? extends BaseStream<? extends R, ?>> fn)
focal_class.identifier: flatMapStream
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, ? extends BaseStream<? extends R, ?>> fn)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> flatMapStream(final Stream<T> stream, final Function<? super T, ? extends BaseStream<? extends R, ?>> fn)
focal_class.class_method_signature: Streams.flatMapOptional(final Stream<T> stream, final Function<? super T, Optional<? extends R>> fn)
focal_class.full_signature: public final static Stream<R> flatMapOptional(final Stream<T> stream, final Function<? super T, Optional<? extends R>> fn)
focal_class.identifier: flatMapOptional
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, Optional<? extends R>> fn)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> flatMapOptional(final Stream<T> stream, final Function<? super T, Optional<? extends R>> fn)
focal_class.class_method_signature: Streams.flatten(final Stream<Stream<T>> stream)
focal_class.full_signature: public final static Stream<T> flatten(final Stream<Stream<T>> stream)
focal_class.identifier: flatten
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<Stream<T>> stream)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> flatten(final Stream<Stream<T>> stream)
focal_class.class_method_signature: Streams.flatMapCompletableFuture(final Stream<T> stream,
              final Function<? super T, CompletableFuture<? extends R>> fn)
focal_class.full_signature: public final static Stream<R> flatMapCompletableFuture(final Stream<T> stream,
              final Function<? super T, CompletableFuture<? extends R>> fn)
focal_class.identifier: flatMapCompletableFuture
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream,
              final Function<? super T, CompletableFuture<? extends R>> fn)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> flatMapCompletableFuture(final Stream<T> stream,
              final Function<? super T, CompletableFuture<? extends R>> fn)
focal_class.class_method_signature: Streams.flatMapCharSequence(final Stream<T> stream, final Function<? super T, CharSequence> fn)
focal_class.full_signature: public final static Stream<Character> flatMapCharSequence(final Stream<T> stream, final Function<? super T, CharSequence> fn)
focal_class.identifier: flatMapCharSequence
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, CharSequence> fn)
focal_class.return: Stream<Character>
focal_class.signature: Stream<Character> flatMapCharSequence(final Stream<T> stream, final Function<? super T, CharSequence> fn)
focal_class.class_method_signature: Streams.flatMapFile(final Stream<T> stream, final Function<? super T, File> fn)
focal_class.full_signature: public final static Stream<String> flatMapFile(final Stream<T> stream, final Function<? super T, File> fn)
focal_class.identifier: flatMapFile
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, File> fn)
focal_class.return: Stream<String>
focal_class.signature: Stream<String> flatMapFile(final Stream<T> stream, final Function<? super T, File> fn)
focal_class.class_method_signature: Streams.flatMapURL(final Stream<T> stream, final Function<? super T, URL> fn)
focal_class.full_signature: public final static Stream<String> flatMapURL(final Stream<T> stream, final Function<? super T, URL> fn)
focal_class.identifier: flatMapURL
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, URL> fn)
focal_class.return: Stream<String>
focal_class.signature: Stream<String> flatMapURL(final Stream<T> stream, final Function<? super T, URL> fn)
focal_class.class_method_signature: Streams.flatMapBufferedReader(final Stream<T> stream, final Function<? super T, BufferedReader> fn)
focal_class.full_signature: public final static Stream<String> flatMapBufferedReader(final Stream<T> stream, final Function<? super T, BufferedReader> fn)
focal_class.identifier: flatMapBufferedReader
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Function<? super T, BufferedReader> fn)
focal_class.return: Stream<String>
focal_class.signature: Stream<String> flatMapBufferedReader(final Stream<T> stream, final Function<? super T, BufferedReader> fn)
focal_class.class_method_signature: Streams.toBufferingDuplicator(final Iterable<A> it,Supplier<Deque<A>> bufferFactory)
focal_class.full_signature: public static final Tuple2<Iterable<A>, Iterable<A>> toBufferingDuplicator(final Iterable<A> it,Supplier<Deque<A>> bufferFactory)
focal_class.identifier: toBufferingDuplicator
focal_class.modifiers: public static final
focal_class.parameters: (final Iterable<A> it,Supplier<Deque<A>> bufferFactory)
focal_class.return: Tuple2<Iterable<A>, Iterable<A>>
focal_class.signature: Tuple2<Iterable<A>, Iterable<A>> toBufferingDuplicator(final Iterable<A> it,Supplier<Deque<A>> bufferFactory)
focal_class.class_method_signature: Streams.toBufferingDuplicator(final Iterable<A> it)
focal_class.full_signature: public static final Tuple2<Iterable<A>, Iterable<A>> toBufferingDuplicator(final Iterable<A> it)
focal_class.identifier: toBufferingDuplicator
focal_class.modifiers: public static final
focal_class.parameters: (final Iterable<A> it)
focal_class.return: Tuple2<Iterable<A>, Iterable<A>>
focal_class.signature: Tuple2<Iterable<A>, Iterable<A>> toBufferingDuplicator(final Iterable<A> it)
focal_class.class_method_signature: Streams.toBufferingDuplicator(final Iterator<A> iterator)
focal_class.full_signature: public static final Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator)
focal_class.identifier: toBufferingDuplicator
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator)
focal_class.return: Tuple2<Iterator<A>, Iterator<A>>
focal_class.signature: Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator)
focal_class.class_method_signature: Streams.toBufferingDuplicator(final Iterator<A> iterator, final long pos)
focal_class.full_signature: public static final Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator, final long pos)
focal_class.identifier: toBufferingDuplicator
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator, final long pos)
focal_class.return: Tuple2<Iterator<A>, Iterator<A>>
focal_class.signature: Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator, final long pos)
focal_class.class_method_signature: Streams.toBufferingDuplicator(final Iterator<A> iterator, Supplier<Deque<A>> bufferFactory)
focal_class.full_signature: public static final Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator, Supplier<Deque<A>> bufferFactory)
focal_class.identifier: toBufferingDuplicator
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator, Supplier<Deque<A>> bufferFactory)
focal_class.return: Tuple2<Iterator<A>, Iterator<A>>
focal_class.signature: Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator, Supplier<Deque<A>> bufferFactory)
focal_class.class_method_signature: Streams.toBufferingDuplicator(final Iterator<A> iterator, final long pos,Supplier<Deque<A>> bufferFactory)
focal_class.full_signature: public static final Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator, final long pos,Supplier<Deque<A>> bufferFactory)
focal_class.identifier: toBufferingDuplicator
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator, final long pos,Supplier<Deque<A>> bufferFactory)
focal_class.return: Tuple2<Iterator<A>, Iterator<A>>
focal_class.signature: Tuple2<Iterator<A>, Iterator<A>> toBufferingDuplicator(final Iterator<A> iterator, final long pos,Supplier<Deque<A>> bufferFactory)
focal_class.class_method_signature: Streams.toBufferingCopier(final Iterable<A> it, final int copies)
focal_class.full_signature: public static final Seq<Iterable<A>> toBufferingCopier(final Iterable<A> it, final int copies)
focal_class.identifier: toBufferingCopier
focal_class.modifiers: public static final
focal_class.parameters: (final Iterable<A> it, final int copies)
focal_class.return: Seq<Iterable<A>>
focal_class.signature: Seq<Iterable<A>> toBufferingCopier(final Iterable<A> it, final int copies)
focal_class.class_method_signature: Streams.toBufferingCopier(final Iterable<A> it, final int copies,Supplier<Deque<A>> bufferSupplier)
focal_class.full_signature: public static final Seq<Iterable<A>> toBufferingCopier(final Iterable<A> it, final int copies,Supplier<Deque<A>> bufferSupplier)
focal_class.identifier: toBufferingCopier
focal_class.modifiers: public static final
focal_class.parameters: (final Iterable<A> it, final int copies,Supplier<Deque<A>> bufferSupplier)
focal_class.return: Seq<Iterable<A>>
focal_class.signature: Seq<Iterable<A>> toBufferingCopier(final Iterable<A> it, final int copies,Supplier<Deque<A>> bufferSupplier)
focal_class.class_method_signature: Streams.toBufferingCopier(final Iterator<A> iterator, final int copies)
focal_class.full_signature: public static final Seq<Iterator<A>> toBufferingCopier(final Iterator<A> iterator, final int copies)
focal_class.identifier: toBufferingCopier
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator, final int copies)
focal_class.return: Seq<Iterator<A>>
focal_class.signature: Seq<Iterator<A>> toBufferingCopier(final Iterator<A> iterator, final int copies)
focal_class.class_method_signature: Streams.toBufferingCopier(final Iterator<A> iterator, final int copies, Supplier<Deque<A>> bufferSupplier)
focal_class.full_signature: public static final Seq<Iterator<A>> toBufferingCopier(final Iterator<A> iterator, final int copies, Supplier<Deque<A>> bufferSupplier)
focal_class.identifier: toBufferingCopier
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator, final int copies, Supplier<Deque<A>> bufferSupplier)
focal_class.return: Seq<Iterator<A>>
focal_class.signature: Seq<Iterator<A>> toBufferingCopier(final Iterator<A> iterator, final int copies, Supplier<Deque<A>> bufferSupplier)
focal_class.class_method_signature: Streams.toLazyCollection(final Stream<A> stream)
focal_class.full_signature: public static final Collection<A> toLazyCollection(final Stream<A> stream)
focal_class.identifier: toLazyCollection
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<A> stream)
focal_class.return: Collection<A>
focal_class.signature: Collection<A> toLazyCollection(final Stream<A> stream)
focal_class.class_method_signature: Streams.toLazyCollection(final Iterator<A> iterator)
focal_class.full_signature: public static final Collection<A> toLazyCollection(final Iterator<A> iterator)
focal_class.identifier: toLazyCollection
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator)
focal_class.return: Collection<A>
focal_class.signature: Collection<A> toLazyCollection(final Iterator<A> iterator)
focal_class.class_method_signature: Streams.toConcurrentLazyCollection(final Stream<A> stream)
focal_class.full_signature: public static final Collection<A> toConcurrentLazyCollection(final Stream<A> stream)
focal_class.identifier: toConcurrentLazyCollection
focal_class.modifiers: public static final
focal_class.parameters: (final Stream<A> stream)
focal_class.return: Collection<A>
focal_class.signature: Collection<A> toConcurrentLazyCollection(final Stream<A> stream)
focal_class.class_method_signature: Streams.toConcurrentLazyCollection(final Iterator<A> iterator)
focal_class.full_signature: public static final Collection<A> toConcurrentLazyCollection(final Iterator<A> iterator)
focal_class.identifier: toConcurrentLazyCollection
focal_class.modifiers: public static final
focal_class.parameters: (final Iterator<A> iterator)
focal_class.return: Collection<A>
focal_class.signature: Collection<A> toConcurrentLazyCollection(final Iterator<A> iterator)
focal_class.class_method_signature: Streams.windowByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.full_signature: public final static Stream<Streamable<T>> windowByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.identifier: windowByTime
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit t)
focal_class.return: Stream<Streamable<T>>
focal_class.signature: Stream<Streamable<T>> windowByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.class_method_signature: Streams.groupedByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.full_signature: public final static Stream<Seq<T>> groupedByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.identifier: groupedByTime
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit t)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> groupedByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.class_method_signature: Streams.batchByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.full_signature: @Deprecated public final static Stream<Seq<T>> batchByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.identifier: batchByTime
focal_class.modifiers: @Deprecated public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit t)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> batchByTime(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.class_method_signature: Streams.groupedByTime(final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.full_signature: public final static Stream<C> groupedByTime(final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.identifier: groupedByTime
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.return: Stream<C>
focal_class.signature: Stream<C> groupedByTime(final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.class_method_signature: Streams.batchByTime(final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.full_signature: @Deprecated public final static Stream<C> batchByTime(final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.identifier: batchByTime
focal_class.modifiers: @Deprecated public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.return: Stream<C>
focal_class.signature: Stream<C> batchByTime(final Stream<T> stream, final long time, final TimeUnit t,
              final Supplier<C> factory)
focal_class.class_method_signature: Streams.groupedStatefullyUntil(final Stream<T> stream,
              final BiPredicate<Seq<? super T>, ? super T> predicate)
focal_class.full_signature: public final static Stream<Seq<T>> groupedStatefullyUntil(final Stream<T> stream,
              final BiPredicate<Seq<? super T>, ? super T> predicate)
focal_class.identifier: groupedStatefullyUntil
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream,
              final BiPredicate<Seq<? super T>, ? super T> predicate)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> groupedStatefullyUntil(final Stream<T> stream,
              final BiPredicate<Seq<? super T>, ? super T> predicate)
focal_class.class_method_signature: Streams.groupedWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.full_signature: public final static Stream<Seq<T>> groupedWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.identifier: groupedWhile
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> groupedWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.class_method_signature: Streams.batchWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.full_signature: @Deprecated public final static Stream<Seq<T>> batchWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.identifier: batchWhile
focal_class.modifiers: @Deprecated public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> batchWhile(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.class_method_signature: Streams.groupedWhile(final Stream<T> stream, final Predicate<? super T> predicate,
                                                                                                           final Supplier<C> factory)
focal_class.full_signature: public final static Stream<C> groupedWhile(final Stream<T> stream, final Predicate<? super T> predicate,
                                                                                                           final Supplier<C> factory)
focal_class.identifier: groupedWhile
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate,
                                                                                                           final Supplier<C> factory)
focal_class.return: Stream<C>
focal_class.signature: Stream<C> groupedWhile(final Stream<T> stream, final Predicate<? super T> predicate,
                                                                                                           final Supplier<C> factory)
focal_class.class_method_signature: Streams.batchWhile(final Stream<T> stream, final Predicate<? super T> predicate,
              final Supplier<C> factory)
focal_class.full_signature: @Deprecated public final static Stream<C> batchWhile(final Stream<T> stream, final Predicate<? super T> predicate,
              final Supplier<C> factory)
focal_class.identifier: batchWhile
focal_class.modifiers: @Deprecated public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate,
              final Supplier<C> factory)
focal_class.return: Stream<C>
focal_class.signature: Stream<C> batchWhile(final Stream<T> stream, final Predicate<? super T> predicate,
              final Supplier<C> factory)
focal_class.class_method_signature: Streams.groupedUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.full_signature: public final static Stream<Seq<T>> groupedUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.identifier: groupedUntil
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> groupedUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.class_method_signature: Streams.batchUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.full_signature: @Deprecated public final static Stream<Seq<T>> batchUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.identifier: batchUntil
focal_class.modifiers: @Deprecated public final static
focal_class.parameters: (final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> batchUntil(final Stream<T> stream, final Predicate<? super T> predicate)
focal_class.class_method_signature: Streams.groupedBySizeAndTime(final Stream<T> stream, final int size, final long time, final TimeUnit t)
focal_class.full_signature: public final static Stream<Seq<T>> groupedBySizeAndTime(final Stream<T> stream, final int size, final long time, final TimeUnit t)
focal_class.identifier: groupedBySizeAndTime
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int size, final long time, final TimeUnit t)
focal_class.return: Stream<Seq<T>>
focal_class.signature: Stream<Seq<T>> groupedBySizeAndTime(final Stream<T> stream, final int size, final long time, final TimeUnit t)
focal_class.class_method_signature: Streams.groupedBySizeAndTime(final Stream<T> stream, final int size, final long time,
              final TimeUnit t, final Supplier<C> factory)
focal_class.full_signature: public final static Stream<C> groupedBySizeAndTime(final Stream<T> stream, final int size, final long time,
              final TimeUnit t, final Supplier<C> factory)
focal_class.identifier: groupedBySizeAndTime
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int size, final long time,
              final TimeUnit t, final Supplier<C> factory)
focal_class.return: Stream<C>
focal_class.signature: Stream<C> groupedBySizeAndTime(final Stream<T> stream, final int size, final long time,
              final TimeUnit t, final Supplier<C> factory)
focal_class.class_method_signature: Streams.debounce(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.full_signature: public final static Stream<T> debounce(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.identifier: debounce
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit t)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> debounce(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.class_method_signature: Streams.onePer(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.full_signature: public final static Stream<T> onePer(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.identifier: onePer
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit t)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> onePer(final Stream<T> stream, final long time, final TimeUnit t)
focal_class.class_method_signature: Streams.jitter(final Stream<T> stream, final long jitterInNanos)
focal_class.full_signature: public final static Stream<T> jitter(final Stream<T> stream, final long jitterInNanos)
focal_class.identifier: jitter
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final long jitterInNanos)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> jitter(final Stream<T> stream, final long jitterInNanos)
focal_class.class_method_signature: Streams.fixedDelay(final Stream<T> stream, final long time, final TimeUnit unit)
focal_class.full_signature: public final static Stream<T> fixedDelay(final Stream<T> stream, final long time, final TimeUnit unit)
focal_class.identifier: fixedDelay
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final long time, final TimeUnit unit)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> fixedDelay(final Stream<T> stream, final long time, final TimeUnit unit)
focal_class.class_method_signature: Streams.xPer(final Stream<T> stream, final int x, final long time, final TimeUnit t)
focal_class.full_signature: public final static Stream<T> xPer(final Stream<T> stream, final int x, final long time, final TimeUnit t)
focal_class.identifier: xPer
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final int x, final long time, final TimeUnit t)
focal_class.return: Stream<T>
focal_class.signature: Stream<T> xPer(final Stream<T> stream, final int x, final long time, final TimeUnit t)
focal_class.class_method_signature: Streams.hotStream(final Stream<T> stream, final Executor exec)
focal_class.full_signature: public final static Connectable<T> hotStream(final Stream<T> stream, final Executor exec)
focal_class.identifier: hotStream
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Executor exec)
focal_class.return: Connectable<T>
focal_class.signature: Connectable<T> hotStream(final Stream<T> stream, final Executor exec)
focal_class.class_method_signature: Streams.primedHotStream(final Stream<T> stream, final Executor exec)
focal_class.full_signature: public final static Connectable<T> primedHotStream(final Stream<T> stream, final Executor exec)
focal_class.identifier: primedHotStream
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Executor exec)
focal_class.return: Connectable<T>
focal_class.signature: Connectable<T> primedHotStream(final Stream<T> stream, final Executor exec)
focal_class.class_method_signature: Streams.pausableHotStream(final Stream<T> stream, final Executor exec)
focal_class.full_signature: public final static PausableConnectable<T> pausableHotStream(final Stream<T> stream, final Executor exec)
focal_class.identifier: pausableHotStream
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Executor exec)
focal_class.return: PausableConnectable<T>
focal_class.signature: PausableConnectable<T> pausableHotStream(final Stream<T> stream, final Executor exec)
focal_class.class_method_signature: Streams.primedPausableHotStream(final Stream<T> stream, final Executor exec)
focal_class.full_signature: public final static PausableConnectable<T> primedPausableHotStream(final Stream<T> stream, final Executor exec)
focal_class.identifier: primedPausableHotStream
focal_class.modifiers: public final static
focal_class.parameters: (final Stream<T> stream, final Executor exec)
focal_class.return: PausableConnectable<T>
focal_class.signature: PausableConnectable<T> primedPausableHotStream(final Stream<T> stream, final Executor exec)
focal_class.class_method_signature: Streams.tailRec(T initial, Function<? super T, ? extends Stream<? extends Either<T, R>>> fn)
focal_class.full_signature: public static Stream<R> tailRec(T initial, Function<? super T, ? extends Stream<? extends Either<T, R>>> fn)
focal_class.identifier: tailRec
focal_class.modifiers: public static
focal_class.parameters: (T initial, Function<? super T, ? extends Stream<? extends Either<T, R>>> fn)
focal_class.return: Stream<R>
focal_class.signature: Stream<R> tailRec(T initial, Function<? super T, ? extends Stream<? extends Either<T, R>>> fn)
focal_method.body: public final static <T> Tuple2<Stream<T>, Stream<T>> duplicate(final Stream<T> stream) {
  
          final Tuple2<Iterator<T>, Iterator<T>> Tuple2 = Streams.toBufferingDuplicator(stream.iterator());
          return Tuple.tuple(
                            Streams.stream(Tuple2._1()), Streams.stream(Tuple2._2()));
      }
focal_method.class_method_signature: Streams.duplicate(final Stream<T> stream)
focal_method.full_signature: public final static Tuple2<Stream<T>, Stream<T>> duplicate(final Stream<T> stream)
focal_method.identifier: duplicate
focal_method.invocations: toBufferingDuplicator iterator tuple stream _1 stream _2
focal_method.modifiers: public final static
focal_method.parameters: (final Stream<T> stream)
focal_method.return: Tuple2<Stream<T>, Stream<T>>
focal_method.signature: Tuple2<Stream<T>, Stream<T>> duplicate(final Stream<T> stream)