Method Process
Process<TSource, TGateOpening>(IObservable<TSource>, IObservable<TGateOpening>)
Allows a single element from an observable sequence to pass through every time a second sequence emits a notification.
public IObservable<TSource> Process<TSource, TGateOpening>(IObservable<TSource> source, IObservable<TGateOpening> gateOpenings)
Parameters
source
IObservable<TSource>The observable sequence to filter.
gateOpenings
IObservable<TGateOpening>The sequence of gate opening events.
Returns
- IObservable<TSource>
The filtered observable sequence. Every time the
gateOpenings
sequence produces a notification, the next element from thesource
sequence will be allowed through.
Type Parameters
TSource
The type of the elements in the
source
sequence.TGateOpening
The type of the elements in the
gateOpenings
sequence.