如果我在ObserveOn之后使用searchRequestSubject (schedulers.background()),我正确地进入了一个后台线程。我希望使用subscribeOn会将所有的链都放到所提供的线程中?为什么它不这样工作?Thread1: "+Thread.currentThread()))
//.observeOn(schedulers.background()) // this is the current sol
我使用Django通道来支持websockets,并使用他们的组概念向同一组中的多个消费者广播消息。为了在使用者之外发送消息,需要在其他同步代码中调用异步方法。不幸的是,这在测试时出现了问题。'type': 'receive_group_json'}),然后堆栈跟踪读取线程没有事件循环:RuntimeError: There is no cu