using System.Collections.Generic;
public static void Main()
var observable = new BadAsyncEnumerable().ToObservable();
observable.Subscribe(item => { }, error => Console.WriteLine(error.Message)); class BadAsyncEnumerable : IAsyncEnumerable<int>
public IAsyncEnumerator<int> GetAsyncEnumerator(
CancellationToken cancellationToken = default)
throw new Exception("Oops!");
