TakeUntilCancellationToken<TSource> sealed class TakeUntilCancellationToken<TSource> : Producer<TSource, _<TSource>> Relays items to the downstream until the CancellationToken is cancelled. Documentation Code public TakeUntilCancellationToken(IObservable<TSource> source, CancellationToken token)