19 import MyGame.Example.Stat;
54         public void store(Monster request, io.grpc.stub.StreamObserver<Stat> responseObserver) {  in store()
60             Stat stat = GameFactory.createStat("Hello " + request.name(), 100, 10);  in store()  local
61             responseObserver.onNext(stat);  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()
119 …    Stat maxHpStat = GameFactory.createStat(maxHpMonsterName.get(), maxHp.get(), maxHpCount.get());  in computeMinMax()
124 …    Stat minHpStat = GameFactory.createStat(minHpMonsterName.get(), minHp.get(), minHpCount.get());  in computeMinMax()
154         Stat stat = blockingStub.store(monsterRequest);
155         Assert.assertEquals(stat.id(), "Hello " + BIG_MONSTER_NAME);
156         System.out.println("Received stat response from service: " + stat.id());
162         Stat stat = blockingStub.store(monsterRequest);
163         Iterator<Monster> iterator = blockingStub.retrieve(stat);
176       final AtomicReference<Stat> maxHitStat = new AtomicReference<Stat>();
179       StreamObserver<Stat> statObserver = new StreamObserver<Stat>() {
184         public void onNext(Stat stat) {
185           maxHitStat.set(stat);
204       final AtomicReference<Stat> maxHitStat = new AtomicReference<Stat>();
205       final AtomicReference<Stat> minHitStat = new AtomicReference<Stat>();
208       StreamObserver<Stat> statObserver = new StreamObserver<Stat>() {
213         public void onNext(Stat stat) {
214           // We expect the server to send the max stat first and then the min stat.
216             maxHitStat.set(stat);
219             minHitStat.set(stat);