ｇｂ

package com.example.grpc.serviceapl;package com.example.grpc.serviceapl;
import io.grpc.stub.StreamObserver;import java.util.Set;import java.util.concurrent.ConcurrentHashMap;

public class ServiceAplImpl extends ServiceAplServiceGrpc.ServiceAplServiceImplBase { private static Set<StreamObserver<ServiceApl.ServiceAplMessageFromServer>> observers = ConcurrentHashMap.newKeySet();
@Override public StreamObserver<ServiceApl.ServiceAplMessage> serviceApl(StreamObserver<ServiceApl.ServiceAplMessageFromServer> responseObserver) { observers.add(responseObserver);
StreamObserver<ServiceApl.ServiceAplMessage> objStreamObserver = new StreamObserverServerImpl(responseObserver);
return objStreamObserver; }
boolean broadcast(ServiceApl.ServiceAplMessageFromServer message) { for (StreamObserver<ServiceApl.ServiceAplMessageFromServer> observer : observers) { observer.onNext(message); } return true; }}