Definition
Package: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Assembly: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Namespace: MessageHandler.Runtime.StreamProcessing
A standing query builder which returns all messages.
Methods
Method | Description |
---|---|
Build(IObservable |
Builds a standing query. |