Searched refs:serverCallStreamObserver (Results 1 – 7 of 7) sorted by relevance
131 final ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver = in serverReflectionInfo() local134 new ProtoReflectionStreamObserver(getRefreshedIndex(), serverCallStreamObserver); in serverReflectionInfo()135 serverCallStreamObserver.setOnReadyHandler(requestObserver); in serverReflectionInfo()136 serverCallStreamObserver.disableAutoRequest(); in serverReflectionInfo()137 serverCallStreamObserver.request(1); in serverReflectionInfo()144 private final ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver; field in ProtoReflectionService.ProtoReflectionStreamObserver151 ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver) { in ProtoReflectionStreamObserver() argument153 this.serverCallStreamObserver = checkNotNull(serverCallStreamObserver, "observer"); in ProtoReflectionStreamObserver()171 if (serverCallStreamObserver.isReady()) { in handleReflectionRequest()196 serverCallStreamObserver.onCompleted(); in handleReflectionRequest()[all …]
40 final ServerCallStreamObserver<HelloReply> serverCallStreamObserver = in main()42 serverCallStreamObserver.disableAutoRequest(); in main()60 if (serverCallStreamObserver.isReady() && !wasReady) { in main()66 serverCallStreamObserver.request(1); in main()71 serverCallStreamObserver.setOnReadyHandler(onReadyHandler); in main()93 if (serverCallStreamObserver.isReady()) { in main()102 serverCallStreamObserver.request(1); in main()
67 to `ServerCallStreamObserver<> serverCallStreamObserver`68 1. call `serverCallStreamObserver.disableAutoRequest()`71 `serverCallStreamObserver.request(1)`
182 val serverCallStreamObserver = responseObserver as ServerCallStreamObserver<T> in grpcBidirectionalStream() constant204 serverCallStreamObserver.setOnCancelHandler { job.cancel() } in grpcBidirectionalStream()265 val serverCallStreamObserver = responseObserver as ServerCallStreamObserver<T> in grpcServerStream() constant287 serverCallStreamObserver.setOnCancelHandler { job.cancel() } in grpcServerStream()
171 ServerCallStreamObserver<ReserveDeviceResponse> serverCallStreamObserver = in reserveDevice() local212 } else if (!serverCallStreamObserver.isCancelled()) { in reserveDevice()
META-INF/ META-INF/MANIFEST.MF build-data.properties com/ com ...
FileMd5$FileChecksum$1.class FileMd5.java package FileMd5$FileChecksum$1 extends com. ...