0

Идея такова: Вставляю список в БД, подписываюсь на вставку, при успешной вставке, возвращается список id вставленных элементов, по этому списку id прохожусь в цикле и получаю строки по id, записываю строки в массив. После этот массив хочу вывести в консоль.

Описание кода: При вызове метода insert из метода insertDatums(), хочу получить наблюдаемый список insertedDatas, т.к если просто получать список insertedDatas, он почему то пустой. Список insertedDatas не заполняется данными при запуске программы, но при отладке заполняется.. Как из метода subscribe вернуть заполненный список insertedDatas с типом Observable? Или есть другие решения?

    class InspectionsImpl(fragment: Fragment, contextForInspections: Context) : Inspections {

        var datum: Datum? = null

        val repository: AlfaKndRepository = ViewModelProviders.of(fragment).get(AlfaKndViewModel::class.java).repository

        var insertedDatas:  MutableList<Datum>? = null

    override fun insertDatums(): Observable<MutableList<Datum>> {
    //хочу, что бы метод insert вернул заполенный insertedDatas с типом Observable     
return insert(dataForInsert!!)
        }

     private fun insert(datasForInsert: List <Datum>): Observable <MutableList<Datum>> { 
         //вставляю список в БД
         Observable.fromCallable { repository.insertList(datasForInsert) } 
            .subscribeOn(Schedulers.io())  
            .flatMapIterable { it.map { it.toInt() } }.toList() 
            //получаю список id вставленных строк
            .subscribe({ 
                for (it in it.iterator()){
                     //получаю из БД элементы по id
                     repository.getById(it)
                        //хочу записать строки полученные по id в массив insertedDatas, при отладке все записывается, а если запустить код, то массив пуст, поэтому хочу вернуть insertedDatas, как Observable
                        .subscribe({insertedDatas!!.add(it)}, {Log.d(TAG, it.message)})
}
7
  • 1
    Отформатируйте код. И куда вам и что надо вернуть?
    – tym32167
    3 июл 2019 в 12:15
  • может вы читаете данные до того, как они пришли?
    – Komdosh
    3 июл 2019 в 12:24
  • @Komdosh так то оно и есть конечно, тут потоковая работа, при отладке все нормально записывается, а когда прогу запускаю, то по нулям 3 июл 2019 в 12:52
  • Вы имеете в виду что-то такое? Вернуть из insert() Observable.fromCallable { repository.insertList(datasForInsert) }.map {it.map{it.toInt()}}.map{ if(insertedDatas==null) insertedDatas = it.toMutableList() else { insertedDatas.addAll(it) } return insertedDatas } ? Т.е. суть в том, что подписываться вам надо, кажется, не в методе InspectionsImpl класса, а там, где вы его вызываете. Ну и в целом что-то странное и излишнее вы, кажется, делаете
    – ЮрийСПб
    3 июл 2019 в 13:13
  • @ЮрийСПб мне тоже кажется, что я делаю излишние вещи, но как еще получить строки, которые я вставил в БД? 4 июл 2019 в 5:38

1 ответ 1

1

@ЮрийСПб спасибо, так и сделал, мыслил по другому, хотел через цикл, когда проще было через map:

private fun insert(datasForInsert: List<Datum>): Single<MutableList<Datum>> {
   return Observable.fromCallable { repository.insertList(datasForInsert) }
            .subscribeOn(Schedulers.io())
           //перебираем список
           .flatMapIterable {
                //элемент списка приобразовываем в Long
                it.map {
                    it.toInt()
                }
            }
            //объеденить выпущенные элементы из map в список
            .toList()
           .map {
               it.toMutableList()
           }
           .map {
               it.map {it ->
                   repository.getById(it)
               }
           }.map {
               it.toMutableList()
           }.flatMap {
               Single.just(it)
           }
}

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.