Por favor, observe el siguiente código trivial:
class Program { static void Main() { var sw = new Stopwatch(); sw.Start(); try { Task.WhenAny(RunAsync()).GetAwaiter().GetResult(); } catch (TimeoutException) { Console.WriteLine("Timed out"); } Console.WriteLine("Elapsed: " + sw.Elapsed); Console.WriteLine("Press Enter to exit"); Console.ReadLine(); } private static async Task RunAsync() { await Observable.StartAsync(async ct => { for (int i = 0; i < 10; ++i) { await Task.Delay(500, ct); Console.WriteLine("Inside " + i); } return Unit.Default; }).Timeout(TimeSpan.FromMilliseconds(1000)); } }Ejecutarlo genera:
Inside 0 Inside 1 Elapsed: 00:00:01.1723818 Press Enter to exitTenga en cuenta que no hay mensaje de tiempo de espera agotado .
Ahora, si reemplazo Task.WhenAny con Task.WhenAll , esto es lo que obtengo:
Inside 0 Inside 1 Timed out Elapsed: 00:00:01.1362188 Press Enter to exitTenga en cuenta la presencia del mensaje Tiempo agotado esta vez.
Y, si elimino el envoltorio Task.WhenAll y llamo a RunAsync directamente:
Inside 0 Inside 1 Timed out Elapsed: 00:00:01.1267617 Press Enter to exitEl mensaje de tiempo de espera está ahí, como se esperaba.
Entonces, ¿cuál es el trato con Task.WhenAny ? Obviamente interrumpe el método asincrónico, pero ¿dónde está TimeoutException ?
Task.WhenAny no vuelve a generar excepciones de las tareas individuales (a diferencia Task.WhenAll ):
"La tarea devuelta se completará cuando se haya completado alguna de las tareas proporcionadas. La tarea devuelta siempre finalizará en el estado
RanToCompletioncon suResultestablecido en la primera tarea que se completará. Esto es cierto incluso si la primera tarea que se completó terminó enCanceledo estadoFaulted".
Desde Task.WhenAny
Eso significa que se completará con éxito pase lo que pase sin ningún tipo de excepción.
Para volver a lanzar la excepción de la tarea individual completada, debe await la tarea devuelta en sí:
var completedTask = await Task.WhenAny(tasks); // no exception await completedTask; // possible exceptionO en tu caso:
Task.WhenAny(RunAsync()).GetAwaiter().GetResult().GetAwaiter().GetResult();