// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the MIT License. // See the LICENSE file in the project root for more information. using System.Threading.Tasks; namespace System.Reactive.Subjects { internal sealed class AnonymousAsyncSubject : IAsyncSubject { private readonly IAsyncObserver _observer; private readonly IAsyncObservable _observable; public AnonymousAsyncSubject(IAsyncObserver observer, IAsyncObservable observable) { _observer = observer; _observable = observable; } public ValueTask OnCompletedAsync() => _observer.OnCompletedAsync(); public ValueTask OnErrorAsync(Exception error) => _observer.OnErrorAsync(error ?? throw new ArgumentNullException(nameof(error))); public ValueTask OnNextAsync(T value) => _observer.OnNextAsync(value); public ValueTask SubscribeAsync(IAsyncObserver observer) => _observable.SubscribeAsync(observer ?? throw new ArgumentNullException(nameof(observer))); } }