OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:StreamingOutputCallRequest
(Results
1 - 25
of
28
) sorted by null
1
2
/external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/
test_services_pb.rb
48
rpc :StreamingOutputCall,
StreamingOutputCallRequest
, stream(StreamingOutputCallResponse)
55
rpc :FullDuplexCall, stream(
StreamingOutputCallRequest
), stream(StreamingOutputCallResponse)
60
rpc :HalfDuplexCall, stream(
StreamingOutputCallRequest
), stream(StreamingOutputCallResponse)
messages_pb.rb
45
add_message "grpc.testing.
StreamingOutputCallRequest
" do
76
StreamingOutputCallRequest
= Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.
StreamingOutputCallRequest
").msgclass
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
AbstractInteropTest.java
95
import io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
;
502
final
StreamingOutputCallRequest
request =
StreamingOutputCallRequest
.newBuilder()
638
final
StreamingOutputCallRequest
request =
639
StreamingOutputCallRequest
.newBuilder()
667
final List<
StreamingOutputCallRequest
> requests = Arrays.asList(
668
StreamingOutputCallRequest
.newBuilder()
674
StreamingOutputCallRequest
.newBuilder()
680
StreamingOutputCallRequest
.newBuilder()
686
StreamingOutputCallRequest
.newBuilder(
[
all
...]
TestServiceImpl.java
38
import io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
;
135
public void streamingOutputCall(
StreamingOutputCallRequest
request,
175
public StreamObserver<Messages.
StreamingOutputCallRequest
> fullDuplexCall(
178
return new StreamObserver<
StreamingOutputCallRequest
>() {
180
public void onNext(
StreamingOutputCallRequest
request) {
211
public StreamObserver<Messages.
StreamingOutputCallRequest
> halfDuplexCall(
215
return new StreamObserver<
StreamingOutputCallRequest
>() {
217
public void onNext(
StreamingOutputCallRequest
request) {
384
public Queue<Chunk> toChunkQueue(
StreamingOutputCallRequest
request) {
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
TestServiceGrpc.java
130
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
,
135
requestType = io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
.class,
138
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
,
140
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStreamingOutputCallMethod;
145
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
151
io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
.getDefaultInstance()))
194
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
,
199
requestType = io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
.class,
202
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
,
204
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFullDuplexCallMethod
[
all
...]
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
StreamingOutputCallRequest.php
14
* Generated from protobuf message <code>grpc.testing.
StreamingOutputCallRequest
</code>
16
class
StreamingOutputCallRequest
extends \Google\Protobuf\Internal\Message
TestServiceClient.php
86
* @param \Grpc\Testing\
StreamingOutputCallRequest
$argument input argument
90
public function StreamingOutputCall(\Grpc\Testing\
StreamingOutputCallRequest
$argument,
/external/grpc-grpc/test/cpp/interop/
interop_client.cc
425
StreamingOutputCallRequest
request;
530
StreamingOutputCallRequest
request;
589
StreamingOutputCallRequest
request;
632
std::unique_ptr<ClientReaderWriter<
StreamingOutputCallRequest
,
636
StreamingOutputCallRequest
request;
679
std::unique_ptr<ClientReaderWriter<
StreamingOutputCallRequest
,
683
StreamingOutputCallRequest
request;
746
std::unique_ptr<ClientReaderWriter<
StreamingOutputCallRequest
,
750
StreamingOutputCallRequest
request;
783
std::unique_ptr<ClientReaderWriter<
StreamingOutputCallRequest
,
[
all
...]
interop_server.cc
64
using grpc::testing::
StreamingOutputCallRequest
;
194
ServerContext* context, const
StreamingOutputCallRequest
* request,
256
StreamingOutputCallRequest
>* stream) {
258
StreamingOutputCallRequest
request;
292
StreamingOutputCallRequest
>* stream) {
293
std::vector<
StreamingOutputCallRequest
> requests;
294
StreamingOutputCallRequest
request;
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
ConcurrencyTest.java
31
import io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
;
113
StreamingOutputCallRequest
.Builder requestBuilder =
StreamingOutputCallRequest
.newBuilder()
120
StreamingOutputCallRequest
request = requestBuilder.build();
Http2OkHttpTest.java
117
Messages.
StreamingOutputCallRequest
.Builder requestBuilder =
118
Messages.
StreamingOutputCallRequest
.newBuilder()
125
StreamObserver<Messages.
StreamingOutputCallRequest
> requestStream =
127
Messages.
StreamingOutputCallRequest
request = requestBuilder.build();
NettyFlowControlTest.java
33
import io.grpc.testing.integration.Messages.
StreamingOutputCallRequest
;
137
StreamingOutputCallRequest
.Builder builder =
StreamingOutputCallRequest
.newBuilder()
143
StreamingOutputCallRequest
request = builder.build();
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
TestServiceImpl.cs
49
public override async Task StreamingOutputCall(
StreamingOutputCallRequest
request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
74
public override async Task FullDuplexCall(IAsyncStreamReader<
StreamingOutputCallRequest
> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
89
public override Task HalfDuplexCall(IAsyncStreamReader<
StreamingOutputCallRequest
> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
GeneratedClientTest.cs
51
Assert.Throws(typeof(NotImplementedException), () => unimplementedClient.StreamingOutputCall(new
StreamingOutputCallRequest
()));
InteropClient.cs
246
var request = new
StreamingOutputCallRequest
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) });
506
var request = new
StreamingOutputCallRequest
548
var request = new
StreamingOutputCallRequest
{ ResponseStatus = echoStatus };
TestGrpc.cs
40
static readonly grpc::Marshaller<global::Grpc.Testing.
StreamingOutputCallRequest
> __Marshaller_grpc_testing_StreamingOutputCallRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.
StreamingOutputCallRequest
.Parser.ParseFrom);
66
static readonly grpc::Method<global::Grpc.Testing.
StreamingOutputCallRequest
, global::Grpc.Testing.StreamingOutputCallResponse> __Method_StreamingOutputCall = new grpc::Method<global::Grpc.Testing.
StreamingOutputCallRequest
, global::Grpc.Testing.StreamingOutputCallResponse>(
80
static readonly grpc::Method<global::Grpc.Testing.
StreamingOutputCallRequest
, global::Grpc.Testing.StreamingOutputCallResponse> __Method_FullDuplexCall = new grpc::Method<global::Grpc.Testing.
StreamingOutputCallRequest
, global::Grpc.Testing.StreamingOutputCallResponse>(
87
static readonly grpc::Method<global::Grpc.Testing.
StreamingOutputCallRequest
, global::Grpc.Testing.StreamingOutputCallResponse> __Method_HalfDuplexCall = new grpc::Method<global::Grpc.Testing.
StreamingOutputCallRequest
, global::Grpc.Testing.StreamingOutputCallResponse>(
153
public virtual global::System.Threading.Tasks.Task StreamingOutputCall(global::Grpc.Testing.
StreamingOutputCallRequest
request, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context)
179
public virtual global::System.Threading.Tasks.Task FullDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.
StreamingOutputCallRequest
> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> respon (…)
[
all
...]
GeneratedServiceBaseTest.cs
79
var call = client.StreamingOutputCall(new
StreamingOutputCallRequest
());
MetadataCredentialsTest.cs
112
var call = client.StreamingOutputCall(new
StreamingOutputCallRequest
{ });
134
var call = client.StreamingOutputCall(new
StreamingOutputCallRequest
{ },
179
public override async Task StreamingOutputCall(
StreamingOutputCallRequest
request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
/external/grpc-grpc/src/php/tests/interop/
interop_client.php
268
$request = new Grpc\Testing\
StreamingOutputCallRequest
();
303
$request = new Grpc\Testing\
StreamingOutputCallRequest
();
363
$request = new Grpc\Testing\
StreamingOutputCallRequest
();
383
$request = new Grpc\Testing\
StreamingOutputCallRequest
();
441
$streaming_request = new Grpc\Testing\
StreamingOutputCallRequest
();
488
$streaming_request = new Grpc\Testing\
StreamingOutputCallRequest
();
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
methods.py
180
request = messages_pb2.
StreamingOutputCallRequest
(
251
request = messages_pb2.
StreamingOutputCallRequest
(
290
request = messages_pb2.
StreamingOutputCallRequest
(
315
request = messages_pb2.
StreamingOutputCallRequest
(
356
request = messages_pb2.
StreamingOutputCallRequest
(
407
request = messages_pb2.
StreamingOutputCallRequest
(
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
_python_plugin_test.py
201
request = request_pb2.
StreamingOutputCallRequest
()
210
request = request_pb2.
StreamingOutputCallRequest
()
213
request = request_pb2.
StreamingOutputCallRequest
()
454
request = request_pb2.
StreamingOutputCallRequest
()
457
request = request_pb2.
StreamingOutputCallRequest
()
485
request = request_pb2.
StreamingOutputCallRequest
()
beta_python_plugin_test.py
266
request = requests_pb2.
StreamingOutputCallRequest
()
275
request = requests_pb2.
StreamingOutputCallRequest
()
278
request = requests_pb2.
StreamingOutputCallRequest
()
611
request = self._requests_pb2.
StreamingOutputCallRequest
()
614
request = self._requests_pb2.
StreamingOutputCallRequest
()
644
request = self._requests_pb2.
StreamingOutputCallRequest
()
/external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
messages_pb.rb
45
add_message "grpc.testing.
StreamingOutputCallRequest
" do
76
StreamingOutputCallRequest
= Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.
StreamingOutputCallRequest
").msgclass
/external/grpc-grpc/src/ruby/pb/test/
client.rb
191
req_cls, p_cls =
StreamingOutputCallRequest
, ResponseParameters # short
225
req_cls =
StreamingOutputCallRequest
433
req =
StreamingOutputCallRequest
.new(response_type: :COMPRESSABLE,
555
req_cls, p_cls =
StreamingOutputCallRequest
, ResponseParameters
620
req_cls, p_cls =
StreamingOutputCallRequest
, ResponseParameters
/external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
Messages.java
[
all
...]
Completed in 1039 milliseconds
1
2