36 references to _runningStreams
InMemory.FunctionalTests (36)
Http2\Http2ConnectionTests.cs (12)
1933_runningStreams[streamId].SetResult(); 1937_runningStreams[streamId].SetException(ex); 3242_runningStreams[streamId].SetResult(); 3246_runningStreams[streamId].SetException(ex); 3287await _runningStreams[1].Task.DefaultTimeout(); 3308await _runningStreams[3].Task.DefaultTimeout(); 3352_runningStreams[streamId].SetResult(); 3356_runningStreams[streamId].SetException(ex); 4265_runningStreams[streamId].SetResult(); 4269_runningStreams[streamId].SetException(ex); 4359_runningStreams[streamId].SetResult(); 4363_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();