OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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