Lines Matching refs:RequestStream
232 await call.RequestStream.WriteAllAsync(bodySizes); in RunClientStreamingAsync()
265 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
274 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
283 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
292 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
301 await call.RequestStream.CompleteAsync(); in RunPingPongAsync()
313 await call.RequestStream.CompleteAsync(); in RunEmptyStreamAsync()
424 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunCancelAfterFirstResponseAsync()
458 …await call.RequestStream.WriteAsync(new StreamingOutputCallRequest { Payload = CreateZerosPayload(… in RunTimeoutOnSleepingServerAsync()
514 await call.RequestStream.WriteAsync(request); in RunCustomMetadataAsync()
515 await call.RequestStream.CompleteAsync(); in RunCustomMetadataAsync()
551 await call.RequestStream.WriteAsync(request); in RunStatusCodeAndMessageAsync()
552 await call.RequestStream.CompleteAsync(); in RunStatusCodeAndMessageAsync()
636 await probeCall.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
655 await call.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
664 call.RequestStream.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in RunClientCompressedStreamingAsync()
665 await call.RequestStream.WriteAsync(new StreamingInputCallRequest in RunClientCompressedStreamingAsync()
673 await call.RequestStream.CompleteAsync(); in RunClientCompressedStreamingAsync()