SignalR Stream is will throw when combined with ToObservable from IX.net, and the stream completes. #28241
Description
public class FooHub : Hub
{
public IAsyncEnumerable<int> Foo()
{
return AsyncEnumerable.Empty<int>();
}
}
public static class Program
{
public async Task Main()
{
await new HubConnectionBuilder()
.WithUrl(....)
.Build()
.StreamAsync(nameof(FooHub.Foo))
.ToObservable()
.Do(x => Console.WriteLine(x))
.ToTask();
}
}
This will throw an exception of CancellationTokenSource ObjectDisposedException.