29var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 56var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();

112var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 156var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 208Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 253Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 299var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 354var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 421var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 925Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 962Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1010var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 1060Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1105Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1158var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout();

390var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 399Assert.False(interactions.Interactions.Reader.TryRead(out _)); 419Assert.False(interactions.Interactions.Reader.TryRead(out _));

141Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 160Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 174var messageBarInteraction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 178var inputsInteraction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 281var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 289var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 374var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 385Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 388Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 395var newNotification = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 425var prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 434prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 443Assert.False(interactions.Interactions.Reader.TryRead(out _)); 453prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 461prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 468Assert.False(interactions.Interactions.Reader.TryRead(out _)); 558var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 562var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 608var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 612var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 651var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 655var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 686var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 690var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 725var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 729var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1291var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1322var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1325var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1369var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1372var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1399var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1403var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1427var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1470var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1625var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1627var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1649var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1651var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1850var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1853var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1891var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1894var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1935var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1938var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2021var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2026var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2051Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 2116notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2168interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2170interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2179interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2181interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2284var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2334var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2372var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2419var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2459var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2463var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2510var setInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2520var deleteInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2532var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2536var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();

26Assert.False(interactions.Interactions.Reader.TryRead(out _)); 42Assert.False(interactions.Interactions.Reader.TryRead(out _)); 57var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 64Assert.False(interactions.Interactions.Reader.TryRead(out _)); 87var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 96Assert.False(interactions.Interactions.Reader.TryRead(out _)); 131var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 164var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout();

403var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 434Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 459var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 467Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));

1299var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1473var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1530Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 1868var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1921var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout();

46Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data); 69Interactions.Writer.TryWrite(data); 76Interactions.Writer.TryWrite(data); 112Interactions.Writer.TryWrite(data);

37var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 97interactionService.Interactions.Writer.Complete(); 101Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 131var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 174var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 181interactionService.Interactions.Writer.Complete(); 182Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 212interactionService.Interactions.Writer.Complete(); 217Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 241interactionService.Interactions.Writer.Complete(); 246Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 282interactionService.Interactions.Writer.Complete(); 283Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 287var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 317var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 346var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 374var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();