Method Process
Process(IObservable<HarpMessage>)
Returns an observable sequence of Harp messages matching the specified address.
public override IObservable<HarpMessage> Process(IObservable<HarpMessage> source)
Parameters
source
IObservable<HarpMessage>An observable sequence of Harp messages.
Returns
- IObservable<HarpMessage>
An observable sequence of Harp messages matching the specified address. If no address is specified, all messages will be accepted.