HomeSort by relevance Sort by last modified time
    Searched refs:WriteAsync (Results 1 - 25 of 29) sorted by null

1 2

  /external/grpc-grpc/src/csharp/Grpc.Core.Tests/
CompressionTest.cs 79 await responseStream.WriteAsync("X");
82 await responseStream.WriteAsync("Y");
85 await responseStream.WriteAsync("Z");
95 await call.RequestStream.WriteAsync("A");
98 await call.RequestStream.WriteAsync("B");
101 await call.RequestStream.WriteAsync("C");
MarshallingErrorsTest.cs 95 await responseStream.WriteAsync("UNPARSEABLE_VALUE");
135 await call.RequestStream.WriteAsync("UNPARSEABLE_VALUE");
161 await call.RequestStream.WriteAsync("A");
162 Assert.ThrowsAsync<IOException>(async () => await call.RequestStream.WriteAsync("UNSERIALIZABLE_VALUE"));
163 await call.RequestStream.WriteAsync("B");
ResponseHeadersTest.cs 106 await responseStream.WriteAsync("PASS");
124 await responseStream.WriteAsync(requestStream.Current);
175 await responseStream.WriteAsync("A");
184 await responseStream.WriteAsync("B");
CallCancellationTest.cs 155 await responseStream.WriteAsync("abc");
  /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
WorkerServiceImpl.cs 48 await responseStream.WriteAsync(new ServerStatus
58 await responseStream.WriteAsync(new ServerStatus
72 await responseStream.WriteAsync(new ClientStatus
80 await responseStream.WriteAsync(new ClientStatus
TestServiceImpl.cs 57 await responseStream.WriteAsync(response);
84 await responseStream.WriteAsync(response);
InteropClient.cs 265 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
274 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
283 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
292 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
424 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest
458 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest { Payload = CreateZerosPayload(27182) });
514 await call.RequestStream.WriteAsync(request);
551 await call.RequestStream.WriteAsync(request);
636 await probeCall.RequestStream.WriteAsync(new StreamingInputCallRequest
655 await call.RequestStream.WriteAsync(new StreamingInputCallReques
    [all...]
BenchmarkServiceImpl.cs 49 await responseStream.WriteAsync(response);
ServerRunners.cs 108 await responseStream.WriteAsync(response);
ClientRunners.cs 263 await call.RequestStream.WriteAsync(request);
291 await call.RequestStream.WriteAsync(request);
MetadataCredentialsTest.cs 187 await responseStream.WriteAsync(new StreamingOutputCallResponse());
  /external/libbrillo/brillo/streams/
mock_stream.h 46 MOCK_METHOD5(WriteAsync, bool(const void*,
stream.h 40 // Stream::WriteAsync() and similar will call MessageLoop::current() to access
290 virtual bool WriteAsync(const void* buffer,
296 // Similar to WriteAsync() operation above but writes exactly |size_to_write|
299 // The rest of restrictions and conditions of WriteAsync() method applies to
438 // The internal implementation of WriteAsync() and WriteAllAsync().
stream_unittest.cc 64 // Omitted: WriteAsync
357 TEST(Stream, WriteAsync) {
376 EXPECT_TRUE(stream_mock.WriteAsync(buf, sizeof(buf), success_callback,
382 EXPECT_FALSE(stream_mock.WriteAsync(buf, sizeof(buf), success_callback,
input_stream_set_unittest.cc 57 EXPECT_FALSE(stream_->WriteAsync(buffer, sizeof(buffer), {}, {}, nullptr));
stream.cc 102 bool Stream::WriteAsync(const void* buffer,
  /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/
AsyncCallServerTest.cs 126 Assert.Throws(typeof(InvalidOperationException), () => responseStream.WriteAsync("request1"));
136 var writeTask = responseStream.WriteAsync("request1");
150 var writeTask = responseStream.WriteAsync("request1");
171 Assert.ThrowsAsync(typeof(InvalidOperationException), async () => await responseStream.WriteAsync("request1"));
AsyncCallTest.cs 183 var writeTask = requestStream.WriteAsync("request1");
187 var writeTask2 = requestStream.WriteAsync("request2");
209 var writeTask = requestStream.WriteAsync("request1");
232 var writeTask = requestStream.WriteAsync("request1");
253 var writeTask = requestStream.WriteAsync("request1");
258 Assert.Throws(typeof(InvalidOperationException), () => requestStream.WriteAsync("request2"));
269 var ex2 = Assert.ThrowsAsync<RpcException>(async () => await requestStream.WriteAsync("after call has finished"));
288 var writeTask = requestStream.WriteAsync("request1");
306 var writeTask = requestStream.WriteAsync("request1");
319 Assert.Throws(typeof(InvalidOperationException), () => requestStream.WriteAsync("request1"))
    [all...]
  /external/grpc-grpc/src/csharp/Grpc.Core/Utils/
AsyncStreamExtensions.cs 65 await streamWriter.WriteAsync(element).ConfigureAwait(false);
81 await streamWriter.WriteAsync(element).ConfigureAwait(false);
  /external/grpc-grpc/src/csharp/Grpc.Examples/
MathServiceImpl.cs 47 await responseStream.WriteAsync(fibEnumerator.Current);
65 await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divArgs)));
  /external/grpc-grpc/src/csharp/Grpc.Core/Internal/
ClientRequestStream.cs 36 public Task WriteAsync(TRequest message)
ServerResponseStream.cs 38 public Task WriteAsync(TResponse message)
  /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideServer/
RouteGuideImpl.cs 59 await responseStream.WriteAsync(response);
114 await responseStream.WriteAsync(prevNote);
  /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideClient/
Program.cs 125 await call.RequestStream.WriteAsync(point);
181 await call.RequestStream.WriteAsync(request);
  /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/
ClientInterceptorTest.cs 207 public Task WriteAsync(T message)
213 return writer.WriteAsync(message);

Completed in 361 milliseconds

1 2