Package org.comroid.mutatio.proc

Interface Processor<T>

All Superinterfaces:

java.lang.AutoCloseable, java.lang.Cloneable, Reference<T>, org.comroid.api.SelfDeclared<Reference<T>>, org.comroid.api.Specifiable<Reference<T>>, java.util.function.Supplier<T>

public interface Processor<T>
extends Reference<T>, java.lang.Cloneable, java.lang.AutoCloseable

Cloneable through process().

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	Processor.Support

Nested classes/interfaces inherited from interface org.comroid.mutatio.ref.Reference

Reference.Settable<T>

Method Summary

Modifier and Type	Method	Description
default void	close()	Consumes the processor and terminates.
static <T> Processor<T>	empty()
default Processor<T>	filter(java.util.function.Predicate<? super T> predicate)
default <R> Processor<R>	flatMap(java.util.function.Function<? super T,? extends Reference<R>> mapper)
T	get()
default boolean	isPresent()
default <R> Processor<R>	map(java.util.function.Function<? super T,? extends R> mapper)
static <T> Processor<T>	ofConstant(T value)
static <T> Processor<T>	ofOptional(java.util.Optional<T> optional)
static <T> Processor<T>	ofReference(Reference<T> reference)
default Processor<T>	peek(java.util.function.Consumer<? super T> action)
default Processor<T>	process()
static <T> Processor<T>	providedOptional(java.util.function.Supplier<java.util.Optional<T>> supplier)
default Reference.Settable<T>	snapshot()

Methods inherited from interface org.comroid.mutatio.ref.Reference

into, invocable, isNull, orElse, orElseGet, provider, requireNonNull, requireNonNull, stream, test, wrap

Methods inherited from interface org.comroid.api.SelfDeclared

self

Methods inherited from interface org.comroid.api.Specifiable

as, as, isType

Method Detail

isPresent

default boolean isPresent()

ofReference

static <T> Processor<T> ofReference(Reference<T> reference)

empty

static <T> Processor<T> empty()

ofOptional

static <T> Processor<T> ofOptional(java.util.Optional<T> optional)

ofConstant

static <T> Processor<T> ofConstant(T value)

providedOptional

static <T> Processor<T> providedOptional(java.util.function.Supplier<java.util.Optional<T>> supplier)

get

@Nullable
T get()

Specified by:

get in interface Reference<T>

Specified by:

get in interface java.util.function.Supplier<T>

close

default void close()

Consumes the processor and terminates. Used for completing some calls that return processors.

Specified by:

close in interface java.lang.AutoCloseable

process

default Processor<T> process()

Specified by:

process in interface Reference<T>

filter

default Processor<T> filter(java.util.function.Predicate<? super T> predicate)

map

default <R> Processor<R> map(java.util.function.Function<? super T,? extends R> mapper)

peek

default Processor<T> peek(java.util.function.Consumer<? super T> action)

flatMap

default <R> Processor<R> flatMap(java.util.function.Function<? super T,? extends Reference<R>> mapper)

snapshot

default Reference.Settable<T> snapshot()