Uses of Interface
com.gengoai.function.SerializableConsumer
-
Packages that use SerializableConsumer Package Description com.gengoai.function Checked and Serializable versions of Java 8's functional elements.com.gengoai.io.resource A mix between Java's FileSystem and Spring's Resourcecom.gengoai.stream A unified stream interface that can work across Java and Spark streams.com.gengoai.stream.spark -
-
Uses of SerializableConsumer in com.gengoai.function
Methods in com.gengoai.function that return SerializableConsumer Modifier and Type Method Description default SerializableConsumer<T>
SerializableFunction. asConsumer()
As consumer serializable consumer.static <T> SerializableConsumer<T>
SerializableFunction. asConsumer(SerializableFunction<T,?> function)
As consumer serializable consumer.static <T> SerializableConsumer<T>
Unchecked. consumer(CheckedConsumer<T> checked)
Generates a version of Consumer that will capture exceptions and rethrow them as runtime exceptionsstatic <T> SerializableConsumer<T>
Unchecked. consumer(CheckedConsumer<T> consumer, SerializableFunction<Throwable,Throwable> throwableHandler)
Methods in com.gengoai.function with parameters of type SerializableConsumer Modifier and Type Method Description static <T,R>
SerializableFunction<T,R>SerializableConsumer. asFunction(SerializableConsumer<T> consumer)
static <T,R>
SerializableFunction<T,R>SerializableConsumer. asFunction(SerializableConsumer<T> consumer, R returnValue)
static <T> Consumer<T>
Serialized. consumer(SerializableConsumer<T> serialized)
Generates a serialized version of Consumer -
Uses of SerializableConsumer in com.gengoai.io.resource
Methods in com.gengoai.io.resource with parameters of type SerializableConsumer Modifier and Type Method Description default void
Resource. forEach(@NonNull SerializableConsumer<String> consumer)
For each. -
Uses of SerializableConsumer in com.gengoai.stream
Methods in com.gengoai.stream with parameters of type SerializableConsumer Modifier and Type Method Description void
MStream. forEach(SerializableConsumer<? super T> consumer)
Performs an operation on each item in the streamvoid
MStream. forEachLocal(SerializableConsumer<? super T> consumer)
Performs an operation on each item in the stream ensuring that is done locally and not distributed. -
Uses of SerializableConsumer in com.gengoai.stream.spark
Methods in com.gengoai.stream.spark with parameters of type SerializableConsumer Modifier and Type Method Description void
SparkStream. forEach(SerializableConsumer<? super T> consumer)
void
SparkStream. forEachLocal(SerializableConsumer<? super T> consumer)
-