RxJava Subject: Слушайте другой тип, который тот, который он испускает

Я провоцировал события цепочек Rx, и у меня проблемы с получением того, что я хочу работать.

Я в основном запрашиваю разрешение пользователя, запрашивая местоположение пользователя, если он был предоставлен, а затем запрашивает данные из API. Ниже приведен код из ViewModel и я хочу, чтобы мой View (технически Fragment ) прослушивался. Моя проблема с приведенным ниже кодом заключается в том, что (очевидно), моя первая планшет не вызывается, поскольку никакое начальное событие не вызывает мой Subject . Я пробовал несколько вариантов этого кода, но не могу найти правильный синтаксис для того, чего я пытаюсь достичь.

Любая помощь будет принята с благодарностью.

 var dataSubject = PublishSubject.create<Array<Data>>() fun getData() : Observable<Array<Data>> { dataSubject .flatMap { permissions.request(Manifest.permission.ACCESS_COARSE_LOCATION) } .flatMap { granted: Boolean -> if (granted) { locationProvider.lastKnownLocation } else { throw Error() } } .flatMap { location: Location -> dataRepository.getData(location.latitude, location.longitude) } return dataSubject } 

Intereting Posts
Сбор данных из разных снимков в FirebaseAdapter Зависимости Bintray не будут загружаться в InteliJ Как получить фиксированное количество изменяемых размеров ячеек без заполнения в javafx? Побитовая операция «и» в котлин Kotlin coroutines: использование синхронного использования cassandra vs для перевода асинхронного использования Kotlin: Как получить доступ к методам get и setValue для делегата? Аргумент функции Котлина без аннотации типа Kotlin: Когда функция расширения скрывает реализацию по умолчанию класса? Почему я должен возвращать Unit.INSTANCE при реализации на Java функции Kotlin, которая возвращает Unit? Пользовательский геттер для свойств параметров типа Как проверить видимость программной клавиатуры в Android? Я смутился со следующим заявлением Котлина Как вы вводите параметры имени поля в Котлин с помощью кинжала 2? Как имитировать или достигать отношения IS-A для классов данных Kotlin Kotlin switch-statement с более чем двумя переменными?