using System.Runtime.CompilerServices; namespace System.Reactive.Joins { internal interface IJoinObserver : IDisposable { [System.Runtime.CompilerServices.NullableContext(1)] void Subscribe(object gate); void Dequeue(); } }