在聊天服务中,我们从客户端获取请求并根据它发送响应。但我的情况是,服务器必须从类的外部方法发送一些不同的对象。
例如,
public StreamObserver<SalaryDetails> message(StreamObserver<Employee> responseObserver) {
observers.add(responseObserver);
return new StreamObserver<SalaryDetails>() {
@Override
public void onCompleted() {
observers.remove(responseObserver);
}
@Override
public void onError(Throwable arg0) {
observers.remove(responseObserver);
}
@Override
public void onNext(SalaryDetails details) {
for(StreamObserver<MetricsToVE> observer : observers) {
**observer.onNext(Employee.newBuilder()
.setName("AA")
.setCity("B")
.build());**
}
}
};
}
在下面的语句中,我对字段进行了硬编码,我应该如何将对象从不同的方法传递到 grpc 服务类。