36 references to _runningStreams
InMemory.FunctionalTests (36)
Http2\Http2ConnectionTests.cs (12)
1941_runningStreams[streamId].SetResult(); 1945_runningStreams[streamId].SetException(ex); 3250_runningStreams[streamId].SetResult(); 3254_runningStreams[streamId].SetException(ex); 3295await _runningStreams[1].Task.DefaultTimeout(); 3316await _runningStreams[3].Task.DefaultTimeout(); 3360_runningStreams[streamId].SetResult(); 3364_runningStreams[streamId].SetException(ex); 4276_runningStreams[streamId].SetResult(); 4280_runningStreams[streamId].SetException(ex); 4370_runningStreams[streamId].SetResult(); 4374_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();