我正在服务器上运行订阅(然后处理到 redis),但如果客户端断开连接(无论是连接失败还是离开页面),我需要调用操作。这可能吗?经过几天的搜索,我找不到任何文档或示例。
订阅端点示例
@Subscription("Notification")
fun notification(id: UUID): Multi<NotificationDto>? {
return dataSource.pubsub(NotificationDto::class.java)
.subscribe(id.toString())
.broadcast()
.toAllSubscribers()
}