Package io.keldysh.messaging

Interface MessageSink<PAYLOAD>

All Superinterfaces:

Function<MessageFlow<PAYLOAD>,MessageFlow<PAYLOAD>>

public interface MessageSink<PAYLOAD>
extends Function<MessageFlow<PAYLOAD>,MessageFlow<PAYLOAD>>

Method Summary

Modifier and Type	Method	Description
default MessageFlow<PAYLOAD>	apply(MessageFlow<PAYLOAD> messageFlow)
MessageFlow<PAYLOAD>	publish(org.reactivestreams.Publisher<Message<PAYLOAD>> flow)

Methods inherited from interface java.util.function.Function

andThen, compose

Method Details

publish

MessageFlow<PAYLOAD> publish(org.reactivestreams.Publisher<Message<PAYLOAD>> flow)

apply

default MessageFlow<PAYLOAD> apply(MessageFlow<PAYLOAD> messageFlow)

Specified by:

apply in interface Function<MessageFlow<PAYLOAD>,MessageFlow<PAYLOAD>>