using System.Collections.Generic; using System.Runtime.CompilerServices; namespace System.Reactive { [System.Runtime.CompilerServices.NullableContext(1)] [System.Runtime.CompilerServices.Nullable(new byte[] { 0, 1 })] internal abstract class ConcatSink<[System.Runtime.CompilerServices.Nullable(2)] TSource> : TailRecursiveSink<TSource> { protected ConcatSink(IObserver<TSource> observer) : base(observer) { } [return: System.Runtime.CompilerServices.Nullable(new byte[] { 2, 1, 1 })] protected override IEnumerable<IObservable<TSource>> Extract(IObservable<TSource> source) { return (source as IConcatenatable<TSource>)?.GetSources(); } public override void OnCompleted() { Recurse(); } } }