java—是否可以在服务器端处理graphql中的断开连接?

moiiocjp  于 2021-07-08  发布在  Java
关注(0)|答案(0)|浏览(308)

我正在做一个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()?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题