Uses of Interface
com.gengoai.function.SerializableRunnable

Packages that use SerializableRunnable

Package	Description
com.gengoai.function	Checked and Serializable versions of Java 8's functional elements.
com.gengoai.stream	A unified stream interface that can work across Java and Spark streams.
com.gengoai.stream.local
com.gengoai.stream.spark

Uses of SerializableRunnable in com.gengoai.function

Methods in com.gengoai.function that return SerializableRunnable

Modifier and Type	Method	Description
static SerializableRunnable	SerializableRunnable.chain(SerializableRunnable r1, SerializableRunnable r2)
static SerializableRunnable	Unchecked.runnable(CheckedRunnable runnable)

Methods in com.gengoai.function with parameters of type SerializableRunnable

Modifier and Type	Method	Description
static SerializableRunnable	SerializableRunnable.chain(SerializableRunnable r1, SerializableRunnable r2)
static Runnable	Serialized.runnable(SerializableRunnable runnable)	Runnable runnable.

Uses of SerializableRunnable in com.gengoai.stream

Methods in com.gengoai.stream with parameters of type SerializableRunnable

Modifier and Type	Method	Description
MDoubleStream	MDoubleStream.onClose(SerializableRunnable onCloseHandler)	Sets the handler to call when the stream is closed.
MPairStream<T,U>	MPairStream.onClose(SerializableRunnable closeHandler)	Sets the handler to call when the stream is closed.
MStream<T>	MStream.onClose(SerializableRunnable closeHandler)	Sets the handler to call when the stream is closed.

Uses of SerializableRunnable in com.gengoai.stream.local

Methods in com.gengoai.stream.local with parameters of type SerializableRunnable

Modifier and Type	Method	Description
MPairStream<K,V>	AbstractLocalMPairStream.onClose(@NonNull SerializableRunnable closeHandler)
MStream<T>	LocalInMemoryMStream.onClose(SerializableRunnable closeHandler)
MDoubleStream	LocalMDoubleStream.onClose(@NonNull SerializableRunnable onCloseHandler)

Uses of SerializableRunnable in com.gengoai.stream.spark

Methods in com.gengoai.stream.spark with parameters of type SerializableRunnable

Modifier and Type	Method	Description
MPairStream<T,U>	SparkPairStream.onClose(SerializableRunnable closeHandler)
MStream<T>	SparkStream.onClose(SerializableRunnable closeHandler)