Searched refs:writeTask (Results 1 – 3 of 3) sorted by relevance
183 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_MoreRequests_Success()185 writeTask.Wait(); in ClientStreaming_MoreRequests_Success()209 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException()213 Assert.IsFalse(writeTask.IsCompleted); in ClientStreaming_WriteFailureThrowsRpcException()220 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException()232 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException2()241 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException2()253 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException3()265 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException3()288 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteAfterReceivingStatusThrowsRpcException()[all …]
136 var writeTask = responseStream.WriteAsync("request1"); in WriteCompletionFailureThrows()138 Assert.ThrowsAsync(typeof(IOException), async () => await writeTask); in WriteCompletionFailureThrows()150 var writeTask = responseStream.WriteAsync("request1"); in WriteAndWriteStatusCanRunConcurrently()156 Assert.DoesNotThrowAsync(async () => await writeTask); in WriteAndWriteStatusCanRunConcurrently()
1211 ScopedTask writeTask(getDefaultDomain(), "Write"); in link() local