Package io.keldysh.messaging

Interface MessageSource<T>

All Superinterfaces:
org.reactivestreams.Publisher<Message<T>>, Supplier<MessageFlow<T>>
All Known Implementing Classes:
MessageFlow
public interface MessageSource<T> extends org.reactivestreams.Publisher<Message<T>>, Supplier<MessageFlow<T>>

  • Method Summary

    Modifier and Type
    Method
    Description
    default MessageFlow<T>
    flow()
     
    default MessageFlow<T>
    get()
     
    static <U> MessageSource<U>
    of(org.reactivestreams.Publisher<? extends Message<U>> publisher)
     
    static <U> MessageSource<U>
    wrap(org.reactivestreams.Publisher<U> publisher)
     

    Methods inherited from interface org.reactivestreams.Publisher

    subscribe