Package io.keldysh.messaging

Interface Message<PAYLOAD>

All Known Subinterfaces:

Message.Outbound<PAYLOAD>

All Known Implementing Classes:

Message.Outbound.Plain, Message.Plain

public interface Message<PAYLOAD>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	Message.Handler<S,T>
static interface	Message.Mapper<S,T>
static interface	Message.Outbound<PAYLOAD>
static class	Message.Plain<PAYLOAD>

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Void>	acknowledge()
default <T> org.reactivestreams.Publisher<Message<T>>	handle(Function<PAYLOAD,? extends org.reactivestreams.Publisher<T>> handler)
default <T> Message<T>	map(Function<PAYLOAD,T> mapper)
static <PAYLOAD> Message<PAYLOAD>	of(PAYLOAD payload)
static <PAYLOAD> Message<PAYLOAD>	of(PAYLOAD payload, reactor.core.publisher.Mono<Void> acknowledge)
PAYLOAD	payload()
default Message.Outbound<PAYLOAD>	to(String to)

Method Details

payload

PAYLOAD payload()

acknowledge

reactor.core.publisher.Mono<Void> acknowledge()

to

default Message.Outbound<PAYLOAD> to(String to)

of

static <PAYLOAD> Message<PAYLOAD> of(PAYLOAD payload)

of

static <PAYLOAD> Message<PAYLOAD> of(PAYLOAD payload,
 reactor.core.publisher.Mono<Void> acknowledge)

map

default <T> Message<T> map(Function<PAYLOAD,T> mapper)

handle

default <T>
org.reactivestreams.Publisher<Message<T>> handle(Function<PAYLOAD,? extends org.reactivestreams.Publisher<T>> handler)