Удаление IAsyncEnumerator не отменяет базовый токен отмены IAsyncEnumerable. ⇐ C#

[Anonymous]

Похоже, что удаление IAsyncEnumerator сгенерированного IAsyncEnumerable не запускает токен отмены базового IAsyncEnumerable.
В частности, этот модульный тест не выполняет свое единственное утверждение:
[Test]
public async Task test()
{
await foreach (var value in TestData())
break;
}

private static async IAsyncEnumerable TestData([EnumeratorCancellation] CancellationToken ct = default)
{
try
{
yield return 1;
await Task.CompletedTask;
yield return 2;
}
finally
{
Assert.That(ct.IsCancellationRequested, Is.True);
}
}

Я крайне удивлен таким поведением. Существует ли какой-либо стандартный подход к отмене CancellationToken TestData в этом сценарии?
Я мог бы реализовать собственный оператор, но это выглядит крайне неуклюже, поэтому я надеюсь, что есть лучший способ сделать это.[Test]
public async Task this_test_passes()
{
await foreach (var value in CancelWhenUnsubscribed(TestData()))
break;
}

public static async IAsyncEnumerable CancelWhenUnsubscribed(IAsyncEnumerable source, [EnumeratorCancellation] CancellationToken ct = default)
{
using var cts = CancellationTokenSource.CreateLinkedTokenSource(ct);
await using var en = source.GetAsyncEnumerator(cts.Token);
using var _ = Disposable.Create(() => cts.Cancel());
while (await en.MoveNextAsync())
yield return en.Current;
}


Для контекста, почему я пытаюсь это сделать: я использую System.Interactive.Async для объединения нескольких последовательностей IAsyncEnumerable.Его реализация работает таким образом, что при удалении объединенной последовательности она сначала ожидает завершения любых текущих задач MoveNext, а затем удаляет и завершает объединенную последовательность.
В моем конкретном случае это означает, что мне нужно отменить базовый IAsyncEnumerables, когда объединенный завершается, иначе я столкнусь с квази-тупиками. В качестве простого примера, этот тест зависает:
[Test]
public async Task this_test_gets_stuck()
{
await foreach (var value in AsyncEnumerableEx.Merge([TestData(), TestData()]))
break;
}

private static async IAsyncEnumerable TestData([EnumeratorCancellation] CancellationToken ct = default)
{
yield return 1;
await Task.Delay(TimeSpan.FromHours(100), ct);
yield return 2;
}


Подробнее здесь: https://stackoverflow.com/questions/786 ... numerables