当另一个源插入管道时,如何实现调度器继承?

我看不出有什么方法可以做到:

observable
.flatMap {
  val scheduler = Schedulers().current!!
  someOtherObservable
    .observeOn(scheduler)
}

是否有其他方法可以继承调度程序?

更多上下文

我有这样一条管道:

compositeDisposable += Environment
  .lookupDeviceInfo()
  .subscribeOn(scheduler)
  .flatMap { deviceInfo ->
    Device(deviceId = deviceInfo.id)
      .sendCommand()
  .subscribe(
    { result -> /*process result*/ },
    { e -> /*log error*/ })

对于消费者来说,这看起来像是他们将所有的工作都推到了指定的 scheduler :事件来自 lookupDeviceInfo() 从调度程序中得到一个worker的向量,然后他们希望继续使用这个worker。

sendCommand() 将来自另一个事件源的事件中的tee作为实现细节:

sendMessageSingle(deviceId, payload)
.flatMap { sentMessageId ->
  responseObservable
  .filter { it.messageId == sentMessageId }
  .firstOrError()
}

事件流从 responseObservable ,但这些事件都不会矢量化到指定的 调度程序