我正在做一个graphql订阅,我需要捕捉客户端断开连接(有意或超时)的时刻,并执行一些工作,比如清除缓存和取消订阅rx订阅。有可能吗?
我将graphql spring boot starter与graphql java工具结合使用。
这是我的密码:
@Component
public class Subscription implements GraphQLSubscriptionResolver {
@Autowired
InnerService innerService;
public Publisher<Score> talkScores(final String title) {
Observable<Score> observable = Observable.create(e -> {
innerService.internalSubscription(e);
});
ConnectableObservable connectableObservable = observable.share().publish();
connectableObservable.connect();
return connectableObservable.toFlowable(BackpressureStrategy.BUFFER);
}
public void cleanSubscriptions() {
innerService.clean()
}
}
如何在客户端断开连接时运行cleansubscriptions()?
暂无答案!
目前还没有任何答案,快来回答吧!