OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:ServerCallStreamObserver
(Results
1 - 9
of
9
) sorted by null
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
ServerCallStreamObserver.java
32
public abstract class
ServerCallStreamObserver
<V> extends CallStreamObserver<V> {
ServerCalls.java
304
extends
ServerCallStreamObserver
<RespT> {
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
ManualFlowControlServer.java
22
import io.grpc.stub.
ServerCallStreamObserver
;
40
final
ServerCallStreamObserver
<HelloReply>
serverCallStreamObserver
=
41
(
ServerCallStreamObserver
<HelloReply>) responseObserver;
42
serverCallStreamObserver
.disableAutoInboundFlowControl();
57
serverCallStreamObserver
.setOnReadyHandler(new Runnable() {
59
if (
serverCallStreamObserver
.isReady() && wasReady.compareAndSet(false, true)) {
64
serverCallStreamObserver
.request(1);
88
// Check the provided
ServerCallStreamObserver
to see if it is still ready to accept more messages.
89
if (
serverCallStreamObserver
.isReady())
[
all
...]
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
ServerCallsTest.java
89
final AtomicReference<
ServerCallStreamObserver
<Integer>> callObserver =
90
new AtomicReference<
ServerCallStreamObserver
<Integer>>();
96
assertTrue(responseObserver instanceof
ServerCallStreamObserver
);
97
ServerCallStreamObserver
<Integer> serverCallObserver =
98
(
ServerCallStreamObserver
<Integer>) responseObserver;
139
final AtomicReference<
ServerCallStreamObserver
<Integer>> callObserver =
140
new AtomicReference<
ServerCallStreamObserver
<Integer>>();
146
callObserver.set((
ServerCallStreamObserver
<Integer>) responseObserver);
167
final AtomicReference<
ServerCallStreamObserver
<Integer>> callObserver =
168
new AtomicReference<
ServerCallStreamObserver
<Integer>>()
[
all
...]
ClientCallsTest.java
382
final
ServerCallStreamObserver
<Integer> serverCallObserver =
383
(
ServerCallStreamObserver
<Integer>) responseObserver;
453
final SettableFuture<
ServerCallStreamObserver
<Integer>> observerFuture
461
final
ServerCallStreamObserver
<Integer> serverCallObserver =
462
(
ServerCallStreamObserver
<Integer>) responseObserver;
529
ServerCallStreamObserver
<Integer> serverCallObserver = observerFuture.get(5, TimeUnit.SECONDS);
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
AsyncServer.java
28
import io.grpc.stub.
ServerCallStreamObserver
;
222
final
ServerCallStreamObserver
<Messages.SimpleResponse> responseObserver =
223
(
ServerCallStreamObserver
<Messages.SimpleResponse>) observer;
290
final
ServerCallStreamObserver
<Messages.SimpleResponse> responseObserver =
291
(
ServerCallStreamObserver
<Messages.SimpleResponse>) observer;
318
final
ServerCallStreamObserver
<Messages.SimpleResponse> responseObserver =
319
(
ServerCallStreamObserver
<Messages.SimpleResponse>) observer;
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
ProtoReflectionService.java
43
import io.grpc.stub.
ServerCallStreamObserver
;
133
final
ServerCallStreamObserver
<ServerReflectionResponse>
serverCallStreamObserver
=
134
(
ServerCallStreamObserver
<ServerReflectionResponse>) responseObserver;
136
new ProtoReflectionStreamObserver(updateIndexIfNecessary(),
serverCallStreamObserver
);
137
serverCallStreamObserver
.setOnReadyHandler(requestObserver);
138
serverCallStreamObserver
.disableAutoInboundFlowControl();
139
serverCallStreamObserver
.request(1);
146
private final
ServerCallStreamObserver
<ServerReflectionResponse>
serverCallStreamObserver
;
[
all
...]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
CascadingTest.java
41
import io.grpc.stub.
ServerCallStreamObserver
;
235
((
ServerCallStreamObserver
) responseObserver).setOnCancelHandler(new Runnable() {
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
TestServiceImpl.java
29
import io.grpc.stub.
ServerCallStreamObserver
;
88
ServerCallStreamObserver
<SimpleResponse> obs =
89
(
ServerCallStreamObserver
<SimpleResponse>) responseObserver;
Completed in 4028 milliseconds