Searched refs:StreamObserver (Results 1 – 6 of 6) sorted by relevance
24 import io.grpc.stub.StreamObserver;41 StreamObserver<AudioTestHarnessService.CaptureChunk> responseObserver) { in capture()
29 import io.grpc.stub.StreamObserver;70 StreamObserver<AudioTestHarnessService.CaptureChunk> responseObserver) { in capture()
26 import io.grpc.stub.StreamObserver;
42 import io.grpc.stub.StreamObserver;140 AtomicReference<StreamObserver<AudioTestHarnessService.CaptureChunk>> in capture_callsStopOnSessionWhenCanceled()171 new StreamObserver<AudioTestHarnessService.CaptureChunk>() { in capture_callsStopOnSessionWhenCanceled() method
32 import io.grpc.stub.StreamObserver;
28 import io.grpc.stub.StreamObserver;285 implements StreamObserver<AudioTestHarnessService.CaptureChunk> {