using System.Runtime.CompilerServices; namespace System.Reactive { [System.Runtime.CompilerServices.NullableContext(1)] [System.Runtime.CompilerServices.Nullable(new byte[] { 0, 1, 1 })] internal abstract class IdentitySink<[System.Runtime.CompilerServices.Nullable(2)] T> : Sink<T, T> { protected IdentitySink(IObserver<T> observer) : base(observer) { } public override void OnNext(T value) { ForwardOnNext(value); } } }