■

package com.example.grpc.serviceapl;package com.example.grpc.serviceapl;
import java.util.Set;import java.util.concurrent.ConcurrentHashMap;
import com.example.grpc.serviceapl.ServiceApl.ServiceAplMessage;import com.example.grpc.serviceapl.ServiceApl.ServiceAplMessageFromServer;import com.google.protobuf.Timestamp;import io.grpc.stub.StreamObserver;
import java.util.Collections;import java.util.LinkedHashSet;import java.util.List;
public class StreamObserverServerImpl implements StreamObserver<ServiceApl.ServiceAplMessage> { private StreamObserver<ServiceApl.ServiceAplMessageFromServer> observer = null;
public StreamObserverServerImpl(StreamObserver<ServiceApl.ServiceAplMessageFromServer> observer) { this.observer = observer; }
@Override public void onCompleted() {//       observers.remove(responseObserver); int fldsjk = 0; fldsjk = 30;
}
@Override public void onError(Throwable arg0) { // TODO Auto-generated method stub
}
@Override public void onNext(ServiceAplMessage value) { System.out.println(value); //add message ServiceApl.ServiceAplMessage message2 = ServiceApl.ServiceAplMessage.newBuilder().setFrom(value.getFrom()) .setMessage(value.getMessage()).setServermessage("hello").build(); //set message ServiceApl.ServiceAplMessageFromServer message = ServiceApl.ServiceAplMessageFromServer.newBuilder() .setMessage(message2).setTimestamp(Timestamp.newBuilder().setSeconds(System.currentTimeMillis() / 1000)) .build();
this.observer.onNext(message); }
}