@@ -6,7 +6,7 @@ using System.Threading.Tasks;
namespace System.Reactive.Linq
{
- public static class AsyncObservable
+ public static partial class AsyncObservable
public static IAsyncObservable<T> Create<T>(Func<IAsyncObserver<T>, Task<IAsyncDisposable>> subscribeAsync)
- public static class AsyncObserver
+ public static partial class AsyncObserver
public static IAsyncObserver<T> Create<T>(Func<T, Task> onNextAsync, Func<Exception, Task> onErrorAsync, Func<Task> onCompletedAsync)