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 AmbManyArray<[System.Runtime.CompilerServices.Nullable(2)] T> : BasicProducer<T> { private readonly IObservable<T>[] _sources; public AmbManyArray(IObservable<T>[] sources) { _sources = sources; } protected override IDisposable Run(IObserver<T> observer) { return AmbCoordinator<T>.Create(observer, _sources); } } }