#OffTop, #RX может кто-то подсказать как решить такой вопрос: считываются

Question

#OffTop, #RX может кто-то подсказать как решить такой вопрос: считываются

с файла даные по строкам, там их ~50К
дальше делается обработка этих строк по кусками (что и как не имеет значения).
Нюанс в чем: делается оно по "window-ам" и первый window должен быть 4500 строк, а все последующие по 350.
Как такое можно сделать?
Т.е. мне надо изменить .buffer() после первого считывания, не могу понять что и как, потому что buffer() устанавливается перед считыванием

#kotlin #programming #russian

0

22.11.2017

2 ответов

10 просмотров

Konstantin Zolotov

напрашивается что-то типа val linesObs = source.share() val first = lines.take(4500).toList() val second = lines.take(4500).buffer(350) Observable.merge(first, second) Ну с поправкой на ветер в смысле rx2 может потребовать еще там Single в Observale конвертнуть

0

22.11.2017

Igor · Accepted Answer

Igor

Могу только предложить переписать на корутины и в конце сконвертировать их в rx.Single 😏 (а вообще вопрос на имеет отношения к kotlinrx)

0

22.11.2017

169 похожих чатов

#OffTop, #RX может кто-то подсказать как решить такой вопрос: считываются

2 ответов

Похожие вопросы