RxJava Zip не работает должным образом

Я пытаюсь реализовать эту сложную структуру API.

Поэтому я попытался реализовать это с помощью RxJava2 zip для параллельных запросов.

  private fun getDetails(marketDataQuotes: MarketDataQuotes, instrumentById: InstrumentById, subscribe: Subscribe): Observable<DetailsWatchListModel> {
    return Observable.zip(
            getMarketDataQutoes(marketDataQuotes),
            getInstrumentById(instrumentById),
            getSubscribeInstrument(subscribe),
            Function3<MarketDataQuotesResponse, List<InstrumentByIdResponse>, SubscribeResult,DetailsWatchListModel>
            { marketData, instrumentList, subscribeInstrument ->
                detailWatchList(marketData, instrumentList, subscribeInstrument)
            })

}

но столкнулся с этой проблемой

private fun getSubscribeInstrument(subscribe: Subscribe): LiveData<SubscribeResult> {
    val mutableLiveData = MutableLiveData<SubscribeResult>()
    remoteServices.requestSubscribe(subscribe)
            .subscribeOn(Schedulers.io())
            //  .observeOn(AndroidSchedulers.mainThread())
            .subscribeWith(object : ErrorCallBack<BaseResponse<SubscribeResult>>() {
                override fun onSuccess(t: BaseResponse<SubscribeResult>) {
                    L.d("Success of Market data Quotes")
                    // mutableLiveData.value = transform(t)
                }

            })
    return mutableLiveData
}

И другие вызовы API подобны этому с единственной обработкой ошибок и базовой структурой ответа.

И обслуживание нравится

@Headers("Content-Type: application/json")
@POST("instruments/subscription")
fun requestSubscribe(@Body subscribe: Subscribe): Observable<BaseResponse<SubscribeResult>>

Используя Kotlin v1.2.21, retofit 2.3.0, RxJava2 2.1.5 Пожалуйста, дайте мне знать, что я делаю неправильно. Tanx заранее