小编Sam*_*abá的帖子

我正在研究一个用例,要求如果一个observable在一定时间内没有发出值,那么我们应该做一些副作用.

给出一个实际的用例:

• 打开Web套接字连接
• 如果在X时间内没有发送/接收消息,则关闭Web套接字连接并通知用户

这需要在每个发射值上启动计时器,并且在初始订阅observable时启动计时器,然后在指定的时间之后运行某个函数或者直到发出计时器重置的值.我正在努力做到这一点的Rx方式.任何帮助,将不胜感激 :)