using System.Runtime.CompilerServices; namespace System.Reactive.Linq.ObservableImpl { [System.Runtime.CompilerServices.NullableContext(1)] [System.Runtime.CompilerServices.Nullable(new byte[] { 0, 1 })] internal sealed class CombineLatestObserver<[System.Runtime.CompilerServices.Nullable(2)] T> : SafeObserver<T> { private readonly object _gate; private readonly ICombineLatest _parent; private readonly int _index; [System.Runtime.CompilerServices.Nullable(2)] private T _value; [System.Runtime.CompilerServices.Nullable(2)] public T Value { [System.Runtime.CompilerServices.NullableContext(2)] get { return _value; } } public CombineLatestObserver(object gate, ICombineLatest parent, int index) { _gate = gate; _parent = parent; _index = index; } public override void OnNext(T value) { lock (_gate) { _value = value; _parent.Next(_index); } } public override void OnError(Exception error) { Dispose(); lock (_gate) { _parent.Fail(error); } } public override void OnCompleted() { Dispose(); lock (_gate) { _parent.Done(_index); } } } }