Interface IMessageObserver
Inherited Members
System.IObserver<Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>>.OnCompleted()
System.IObserver<Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>>.OnError(System.Exception)
System.IObserver<Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>>.OnNext(Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>)
Namespace: Catalyst.Abstractions.IO.Observers
Assembly: Catalyst.Abstractions.dll
Syntax
public interface IMessageObserver : IObserver<IObserverDto<ProtocolMessage>>Methods
| Improve this Doc View SourceStartObserving(IObservable<IObserverDto<ProtocolMessage>>)
Declaration
void StartObserving(IObservable<IObserverDto<ProtocolMessage>> messageStream)Parameters
| Type | Name | Description |
|---|---|---|
| System.IObservable<IObserverDto<ProtocolMessage>> | messageStream |