如果订阅了 IObservable，控制台应用程序不会正常终止

Question

有一个控制台应用程序并使用Nito.AsyncEx，我有以下入口点。

static int Main(string[] args)
{
var result = -1;
try
{
result = AsyncContext.Run(() => MainAsync(args));
}
catch (Exception ex)
{
Console.Error.WriteLine(ex);
}
#if DEBUG
Console.WriteLine("Press any key to terminate...");
Console.ReadKey();
#endif
return result;
}

我有一个公开IObservable<T>属性的IDisposable类。

private readonly Subject<Tuple<IReadOnlyCollection<dynamic>, string>> _onDataResultsSubject = new Subject<Tuple<IReadOnlyCollection<dynamic>, string>>();
public IObservable<Tuple<IReadOnlyCollection<dynamic>, string>> OnDataResults => _onDataResultsSubject;

MainAsync我订阅了OnDataResults属性。

using (var processor = new Processor())
{
var eventDisposable = processor.OnDataResults
.Select(tuple => Tuple.Create(DataResultsToChunks(tuple.Item1, dataChunkSize), tuple.Item2))
.Select(tuple => DataChunksToMessageEnvelopes(tuple.Item1, tuple.Item2))
.SelectMany(messageEnvelope => PublishMessagesAsync(messageEnvelope, messagingService))
.Subscribe(messagesSent =>
{
var result = messagesSent.Select(p => p.ToString())
.Aggregate((p1, p2) => $"{p1}, {p2}");
Console.WriteLine($"Message sent {result}");
},
ex => Console.Error.WriteLine($"Error: {ex}"));
await processor.ProcessAsync(migrationConfigs).ConfigureAwait(false);
eventDisposable.Dispose();
}

当应用程序成功完成并打印Console.WriteLine("Press any key to terminate...");时，点击任何键都不会终止应用程序。即使在发布模式下，控制台窗口仍保持打开和挂起状态。

删除可识别订阅一切正常。

Answer 1

问题中演示的代码和@clint引起的怀疑与.SelectMany(messageEnvelope => PublishMessagesAsync(messageEnvelope, messagingService))有关。 似乎PublishMessagesAsync持有messagingService与 RabbitMQ 连接的实例。

由于messagingService是我自己的实现，并且实现了IDisposable调用Dispose()并在内部清理资源，因此反应式扩展将不再适用于实例。

爱RX！总是推动你更好的编程：-)