Method Process
Process<TSource>(IObservable<TSource>)
Wraps an observable sequence to ensure all notifications are emitted while holding the Python global interpreter lock.
public override IObservable<TSource> Process<TSource>(IObservable<TSource> source)
Parameters
sourceIObservable<TSource>The source sequence to wrap.
Returns
- IObservable<TSource>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of ensuring that all notifications are emitted inside the Python global interpreter lock.
Type Parameters
TSourceThe type of the elements in the
sourcesequence.