36 references to _runningStreams
InMemory.FunctionalTests (36)
Http2\Http2ConnectionTests.cs (12)
1942_runningStreams[streamId].SetResult(); 1946_runningStreams[streamId].SetException(ex); 3373_runningStreams[streamId].SetResult(); 3377_runningStreams[streamId].SetException(ex); 3418await _runningStreams[1].Task.DefaultTimeout(); 3439await _runningStreams[3].Task.DefaultTimeout(); 3483_runningStreams[streamId].SetResult(); 3487_runningStreams[streamId].SetException(ex); 4408_runningStreams[streamId].SetResult(); 4412_runningStreams[streamId].SetException(ex); 4502_runningStreams[streamId].SetResult(); 4506_runningStreams[streamId].SetException(ex);
Http2\Http2StreamTests.cs (14)
3195_runningStreams[streamIdFeature.StreamId].TrySetResult(); 3230_runningStreams[streamIdFeature.StreamId].TrySetResult(); 3255_runningStreams[streamIdFeature.StreamId].TrySetException(new Exception("ReadAsync was expected to throw.")); 3266_runningStreams[streamIdFeature.StreamId].TrySetResult(); 3270_runningStreams[streamIdFeature.StreamId].TrySetException(ex); 3298_runningStreams[streamIdFeature.StreamId].TrySetException(new Exception("ReadAsync was expected to throw.")); 3309_runningStreams[streamIdFeature.StreamId].TrySetResult(); 3313_runningStreams[streamIdFeature.StreamId].TrySetException(ex); 3343_runningStreams[streamIdFeature.StreamId].TrySetResult(); 3351await _runningStreams[streamIdFeature.StreamId].Task; 3355_runningStreams[streamIdFeature.StreamId].TrySetException(ex); 3383_runningStreams[streamIdFeature.StreamId].TrySetResult(); 3393await _runningStreams[streamIdFeature.StreamId].Task; 3397_runningStreams[streamIdFeature.StreamId].TrySetException(ex);
Http2\Http2TestBase.cs (10)
307_runningStreams[streamIdFeature.StreamId].TrySetResult(); 329_runningStreams[streamIdFeature.StreamId].TrySetResult(); 537if (_httpTestBase._runningStreams.TryGetValue(stream.StreamId, out var tcs)) 618_runningStreams[streamId] = tcs; 633_runningStreams[streamId] = tcs; 652_runningStreams[streamId] = tcs; 694_runningStreams[streamId] = tcs; 739_runningStreams[streamId] = tcs; 773return _runningStreams[streamId].Task; 778return Task.WhenAll(_runningStreams.Values.Select(tcs => tcs.Task)).DefaultTimeout();