Lines Matching refs:StreamObserver

25 import io.grpc.stub.StreamObserver;
54         public void store(Monster request, io.grpc.stub.StreamObserver<Stat> responseObserver) {  in store()
66         public void retrieve(Stat request, io.grpc.stub.StreamObserver<Monster> responseObserver) {  in retrieve()
76         public StreamObserver<Monster> getMaxHitPoint(final StreamObserver<Stat> responseObserver) {  in getMaxHitPoint()
81 …   public StreamObserver<Monster> getMinMaxHitPoints(final StreamObserver<Stat> responseObserver) {  in getMinMaxHitPoints()
85 …private StreamObserver<Monster> computeMinMax(final StreamObserver<Stat> responseObserver, final b…  in computeMinMax()
94           return new StreamObserver<Monster>() {  in computeMinMax()
179       StreamObserver<Stat> statObserver = new StreamObserver<Stat>() {
188       StreamObserver<Monster> monsterStream = asyncStub.getMaxHitPoint(statObserver);
208       StreamObserver<Stat> statObserver = new StreamObserver<Stat>() {
223       StreamObserver<Monster> monsterStream = asyncStub.getMinMaxHitPoints(statObserver);