Home
last modified time | relevance | path

Searched refs:streamingCall (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DAbstractBenchmark.java432 final ClientCall<ByteBuf, ByteBuf> streamingCall = in startStreamingCalls() local
438 streamingCall, in startStreamingCalls()
486 final ClientCall<ByteBuf, ByteBuf> streamingCall = in startFlowControlledStreamingCalls() local
492 streamingCall, in startFlowControlledStreamingCalls()
524 streamingCall.request(5); in startFlowControlledStreamingCalls()
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java235 … public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingCall( in streamingCall() method in BenchmarkServiceGrpc.BenchmarkServiceImplBase
351 … public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingCall( in streamingCall() method in BenchmarkServiceGrpc.BenchmarkServiceStub
509 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingCall( in invoke()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncServer.java220 public StreamObserver<Messages.SimpleRequest> streamingCall( in streamingCall() method in AsyncServer.BenchmarkServiceImpl
DAsyncClient.java200 StreamObserver<SimpleRequest> requestObserver = stub.streamingCall(responseObserver); in doStreamingCalls()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadClient.java383 requestObserver.set(stub.streamingCall( in run()