ServerInterceptor中的grpc-java异步调用

作者: 哎？小查查
发布时间: 2024-12-23 07:19:25 (2月前)
转自：

2 条回复

0#
回复此人
star | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 你需要返回一个 <code> ServerCall.Listener </code> 。但既然你不知道 <code> Listener </code> 委托，您可以覆盖中的每个方法 <code> Listener </code> 将回调添加到队列。身份验证完成后，排空队列。 </p> <pre> <code> class DelayedListener<ReqT> extends Listener<ReqT> { private Listener<ReqT> delegate; private List<Runnable> events = new ArrayList<Runnable>(); @Override public synchronized void onMessage(ReqT message) { if (delegate == null) { events.add(() -> delegate.onMessage(message)); } else { delegate.onMessage(message); } } ... public synchronized void setDelegate(Listener<ReqT> delegate) { this.delegate = delegate; for (Runnable runnable : events) { runnable.run(); } events = null; } } </code> </pre> </DIV>

编辑

登录后才能参与评论