Interface IMessageStreamObservable<TMessage>

Namespace

Silverback.Messaging.Messages

Assembly

Silverback.Core.Rx.dll

Represent a stream of messages being published via the message bus. It is an observable that is asynchronously pushed with messages.

public interface IMessageStreamObservable<out TMessage> : IObservable<TMessage>

Type Parameters

TMessage

The type of the messages being streamed.

Inherited Members

IObservable<TMessage>.Subscribe(IObserver<TMessage>)