Class Hierarchy
- java.lang.Object
- io.keldysh.messaging.Message.Plain<PAYLOAD> (implements io.keldysh.messaging.Message<PAYLOAD>)
- io.keldysh.messaging.Message.Outbound.Plain<PAYLOAD> (implements io.keldysh.messaging.Message.Outbound<PAYLOAD>)
- io.keldysh.messaging.MessageFlow<T> (implements io.keldysh.messaging.MessageSource<T>)
- io.keldysh.messaging.Message.Plain<PAYLOAD> (implements io.keldysh.messaging.Message<PAYLOAD>)
Interface Hierarchy
- java.lang.AutoCloseable
- java.io.Closeable
- io.keldysh.messaging.MessageClient
- java.io.Closeable
- java.util.function.Function<T,
R> - io.keldysh.messaging.Message.Handler<S,
T> - io.keldysh.messaging.Message.Mapper<S,
T> - io.keldysh.messaging.MessageFlow.Handler<T,
U> - io.keldysh.messaging.MessageSink<PAYLOAD>
- io.keldysh.messaging.Message.Handler<S,
- io.keldysh.messaging.Message<PAYLOAD>
- io.keldysh.messaging.Message.Outbound<PAYLOAD>
- org.reactivestreams.Publisher<T>
- io.keldysh.messaging.MessageSource<T> (also extends java.util.function.Supplier<T>)
- java.util.function.Supplier<T>
- io.keldysh.messaging.MessageSource<T> (also extends org.reactivestreams.Publisher<T>)