无法订阅 Flowable

问题描述

我有一个事件列表，对于每个事件，我必须订阅实时更新（网络套接字）。

我请求每个事件如下。

    private fun subscribeToEventUpdates(events: List<Events>): Flowable<Result<EventUpdateResult,EventUpdateError>> {
        val eventUpdates = events.map { subscribeToEventUpdatesUseCase.invoke(it.id)) }

        return Flowable.merge(eventUpdates)
    }

我正在尝试订阅以下事件。

    private fun getUpdatesFoEvents(events: List<Event>) {
        eventUpdatesDisposable?.dispose()
        eventUpdatesDisposable = subscribeToEventUpdates(events)
            .distinctUntilChanged()
            .subscribe(
                { onEventUpdate(it) },{ onEventUpdateFailure(it) }
            )
    }

当我登录 subscribeToEventUpdatesUseCase 时，我看到我收到了网络套接字更新，但从未调用 subscribe 中的 getUpdatesFoEvents 方法。

我怎样才能收到更新？任何帮助将不胜感激。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）