com.aol.cyclops2.internal.stream

Class FutureStreamUtils

java.lang.Object

com.aol.cyclops2.internal.stream.FutureStreamUtils

public class FutureStreamUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
FutureStreamUtils()

Method Summary

Modifier and Type	Method and Description
static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>>	forEachEvent(java.util.stream.Stream<T> stream, java.util.function.Consumer<? super T> consumerElement, java.util.function.Consumer<? super java.lang.Throwable> consumerError, java.lang.Runnable onComplete) Perform a forEach operation over the Stream capturing any elements and errors in the supplied consumers when the entire Stream has been processed an onComplete event will be recieved.
static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>>	forEachWithError(java.util.stream.Stream<T> stream, java.util.function.Consumer<? super T> consumerElement, java.util.function.Consumer<? super java.lang.Throwable> consumerError) Perform a forEach operation over the Stream capturing any elements and errors in the supplied consumers,
static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>>	forEachX(java.util.stream.Stream<T> stream, long x, java.util.function.Consumer<? super T> consumerElement) Perform a forEach operation over the Stream, without closing it, consuming only the specified number of elements from the Stream, at this time.
static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>>	forEachXEvents(java.util.stream.Stream<T> stream, long x, java.util.function.Consumer<? super T> consumerElement, java.util.function.Consumer<? super java.lang.Throwable> consumerError, java.lang.Runnable onComplete) Perform a forEach operation over the Stream without closing it, capturing any elements and errors in the supplied consumers, but only consuming the specified number of elements from the Stream, at this time.
static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>>	forEachXWithError(java.util.stream.Stream<T> stream, long x, java.util.function.Consumer<? super T> consumerElement, java.util.function.Consumer<? super java.lang.Throwable> consumerError) Perform a forEach operation over the Stream without closing it, capturing any elements and errors in the supplied consumers, but only consuming the specified number of elements from the Stream, at this time.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FutureStreamUtils

public FutureStreamUtils()

Method Detail

forEachX

public static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>> forEachX(java.util.stream.Stream<T> stream,
                                                                                                                                                                                                                                             long x,
                                                                                                                                                                                                                                             java.util.function.Consumer<? super T> consumerElement)

Perform a forEach operation over the Stream, without closing it, consuming only the specified number of elements from the Stream, at this time. More elements can be consumed later, by called request on the returned Subscription

 
     Subscription next = Streams.forEach(Stream.of(1,2,3,4),2,System.out::println);
          
     System.out.println("First batch processed!");
     
     next.request(2);
     
      System.out.println("Second batch processed!");
      
     //prints
     1
     2
     First batch processed!
     3
     4 
     Second batch processed!
 
 

Parameters:

stream - - the Stream to consume data from

x - To consume from the Stream at this time

consumerElement - To accept incoming events from the Stream

Returns:

Subscription so that further processing can be continued or cancelled.

forEachXWithError

public static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>> forEachXWithError(java.util.stream.Stream<T> stream,
                                                                                                                                                                                                                                                      long x,
                                                                                                                                                                                                                                                      java.util.function.Consumer<? super T> consumerElement,
                                                                                                                                                                                                                                                      java.util.function.Consumer<? super java.lang.Throwable> consumerError)

Perform a forEach operation over the Stream without closing it, capturing any elements and errors in the supplied consumers, but only consuming the specified number of elements from the Stream, at this time. More elements can be consumed later, by called request on the returned Subscription

 
     Subscription next = Streams.forEach(Stream.of(()->1,()->2,()->throw new RuntimeException(),()->4)
                                  .map(Supplier::get),System.out::println, e->e.printStackTrace());
          
     System.out.println("First batch processed!");
     
     next.request(2);
     
      System.out.println("Second batch processed!");
      
     //prints
     1
     2
     First batch processed!
     
     RuntimeException Stack Trace on System.err
     
     4 
     Second batch processed!
 
 

Parameters:

stream - - the Stream to consume data from

x - To consume from the Stream at this time

consumerElement - To accept incoming elements from the Stream

consumerError - To accept incoming processing errors from the Stream

Returns:

Subscription so that further processing can be continued or cancelled.

forEachXEvents

public static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>> forEachXEvents(java.util.stream.Stream<T> stream,
                                                                                                                                                                                                                                                   long x,
                                                                                                                                                                                                                                                   java.util.function.Consumer<? super T> consumerElement,
                                                                                                                                                                                                                                                   java.util.function.Consumer<? super java.lang.Throwable> consumerError,
                                                                                                                                                                                                                                                   java.lang.Runnable onComplete)

Perform a forEach operation over the Stream without closing it, capturing any elements and errors in the supplied consumers, but only consuming the specified number of elements from the Stream, at this time. More elements can be consumed later, by called request on the returned Subscription, when the entire Stream has been processed an onComplete event will be recieved.

 
     Subscription next = Streams.forEach(Stream.of(()->1,()->2,()->throw new RuntimeException(),()->4)
                                  .map(Supplier::get) ,System.out::println, e->e.printStackTrace(),()->System.out.println("the take!"));
          
     System.out.println("First batch processed!");
     
     next.request(2);
     
      System.out.println("Second batch processed!");
      
     //prints
     1
     2
     First batch processed!
     
     RuntimeException Stack Trace on System.err
     
     4 
     Second batch processed!
     The take!
 
 

Parameters:

stream - - the Stream to consume data from

x - To consume from the Stream at this time

consumerElement - To accept incoming elements from the Stream

consumerError - To accept incoming processing errors from the Stream

onComplete - To run after an onComplete event

Returns:

Subscription so that further processing can be continued or cancelled.

forEachWithError

public static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>> forEachWithError(java.util.stream.Stream<T> stream,
                                                                                                                                                                                                                                                     java.util.function.Consumer<? super T> consumerElement,
                                                                                                                                                                                                                                                     java.util.function.Consumer<? super java.lang.Throwable> consumerError)

Perform a forEach operation over the Stream capturing any elements and errors in the supplied consumers,

 
     Subscription next = StreanUtils.forEach(Stream.of(()->1,()->2,()->throw new RuntimeException(),()->4)
                                  .map(Supplier::get),System.out::println, e->e.printStackTrace());
          
     System.out.println("processed!");
     
    
      
     //prints
     1
     2
     RuntimeException Stack Trace on System.err
     4
     processed!
     
 
 

Parameters:

stream - - the Stream to consume data from

consumerElement - To accept incoming elements from the Stream

consumerError - To accept incoming processing errors from the Stream

Returns:

A Tuple containing a Future with a Subscription to this publisher, a runnable to skip processing on a separate thread, and future that stores true / false depending on success

forEachEvent

public static <T,X extends java.lang.Throwable> org.jooq.lambda.tuple.Tuple3<java.util.concurrent.CompletableFuture<org.reactivestreams.Subscription>,java.lang.Runnable,java.util.concurrent.CompletableFuture<java.lang.Boolean>> forEachEvent(java.util.stream.Stream<T> stream,
                                                                                                                                                                                                                                                 java.util.function.Consumer<? super T> consumerElement,
                                                                                                                                                                                                                                                 java.util.function.Consumer<? super java.lang.Throwable> consumerError,
                                                                                                                                                                                                                                                 java.lang.Runnable onComplete)

Perform a forEach operation over the Stream capturing any elements and errors in the supplied consumers when the entire Stream has been processed an onComplete event will be recieved.

 
     Subscription next = Streams.forEachEvents(Stream.of(()->1,()->2,()->throw new RuntimeException(),()->4)
                                  .map(Supplier::get),System.out::println, e->e.printStackTrace(),()->System.out.println("the take!"));
          
     System.out.println("processed!");
     
      
     //prints
     1
     2
     RuntimeException Stack Trace on System.err
      4 
     processed!
     
     
 
 

Parameters:

stream - - the Stream to consume data from

consumerElement - To accept incoming elements from the Stream

consumerError - To accept incoming processing errors from the Stream

onComplete - To run after an onComplete event

Returns:

A Tuple containing a Future with a Subscription to this publisher, a runnable to skip processing on a separate thread, and future that stores true / false depending on success