Package io.keldysh.messaging

Interface Message.Handler<S,T>

All Superinterfaces:

Function<Message<S>,org.reactivestreams.Publisher<Message<T>>>

Enclosing interface:

Message<PAYLOAD>

public static interface Message.Handler<S,T>
extends Function<Message<S>,org.reactivestreams.Publisher<Message<T>>>

Method Summary

Static Methods

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

Methods inherited from interface java.util.function.Function

andThen, apply, compose

Method Details

of

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

toVoid

static <S> Message.Handler<S,Void> toVoid(Function<? super S,? extends org.reactivestreams.Publisher<Void>> handler)