Searched refs:clientCallStreamObserver (Results 1 – 1 of 1) sorted by relevance
618 ClientCallStreamObserver<StreamingInputCallRequest> clientCallStreamObserver = in clientCompressedStreaming() local621 clientCallStreamObserver.setMessageCompression(true); in clientCompressedStreaming()622 clientCallStreamObserver.onNext(expectCompressedRequest); in clientCompressedStreaming()623 clientCallStreamObserver.setMessageCompression(false); in clientCompressedStreaming()624 clientCallStreamObserver.onNext(expectUncompressedRequest); in clientCompressedStreaming()625 clientCallStreamObserver.onCompleted(); in clientCompressedStreaming()