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
sourceIObservable<TSource>The observable sequence to filter.
gateOpeningsIObservable<TGateOpening>The sequence of gate opening events.
Returns
- IObservable<TSource>
The filtered observable sequence. Every time the
gateOpeningssequence produces a notification, the next element from thesourcesequence will be allowed through.
Type Parameters
TSourceThe type of the elements in the
sourcesequence.TGateOpeningThe type of the elements in the
gateOpeningssequence.