36 references to _runningStreams
InMemory.FunctionalTests (36)
Http2\Http2ConnectionTests.cs (12)
1917_runningStreams[streamId].SetResult(); 1921_runningStreams[streamId].SetException(ex); 3226_runningStreams[streamId].SetResult(); 3230_runningStreams[streamId].SetException(ex); 3271await _runningStreams[1].Task.DefaultTimeout(); 3292await _runningStreams[3].Task.DefaultTimeout(); 3336_runningStreams[streamId].SetResult(); 3340_runningStreams[streamId].SetException(ex); 4249_runningStreams[streamId].SetResult(); 4253_runningStreams[streamId].SetException(ex); 4343_runningStreams[streamId].SetResult(); 4347_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();