Method Process
Process(IObservable<HarpMessage>)
Filters an observable sequence for Harp messages matching the specified message type criteria.
public override IObservable<HarpMessage> Process(IObservable<HarpMessage> source)
Parameters
source
IObservable<HarpMessage>An observable sequence of Harp messages.
Returns
- IObservable<HarpMessage>
An observable sequence including or excluding the Harp messages matching the specified message type, depending on the specified filter type. If message type is null, messages of any type are accepted. Error messages are always rejected.