小编EBa*_*ett的帖子

我有一个 Observable，它以 JSON 字符串的形式发出事件。我想订阅它阻塞并获取第一个字符串。不是问题。

但我也想超时并在超时触发时发出一个罐装 JSON 字符串。

这是我现有的代码：

String jsonString = rxEvents.subscribe().toBlocking().first();