Package io.keldysh.messaging

Interface MessageFlow.Handler<T,U>

All Superinterfaces:

Function<MessageFlow<T>,org.reactivestreams.Publisher<? extends Message<U>>>

Enclosing class:

MessageFlow<T>

public static interface MessageFlow.Handler<T,U>
extends Function<MessageFlow<T>,org.reactivestreams.Publisher<? extends Message<U>>>

Method Summary

Static Methods

Modifier and Type	Method	Description
static <T> MessageFlow.Handler<T,T>	empty()
static <T, U> MessageFlow.Handler<T,U>	of(Function<? super MessageFlow<T>,? extends org.reactivestreams.Publisher<? extends Message<U>>> handler)

Methods inherited from interface java.util.function.Function

andThen, apply, compose

Method Details

empty

static <T> MessageFlow.Handler<T,T> empty()

of

static <T,
U> MessageFlow.Handler<T,U> of(Function<? super MessageFlow<T>,? extends org.reactivestreams.Publisher<? extends Message<U>>> handler)