l
либо если тебе надо количество по завершению стрима (то есть онкомплита), то обычный count
Size: a a a
2021 May 18
v
А как именно в котлине?
A
Но ведь в доке написано совсем другое.
l
вопрос на засыпку: как считать элемент последним, не зная, завершился поток или нет?
v
Я делал предположение, что, теоретически, он может быть последним на момент подписки, например) Но уже понял, что не так работает.
A
Мы про разные вещи говорим. Во-первых, тут речь была про RxJava vs Reactor. Во-вторых, мне кажется странным то, что ивэнт окончания создаётся уже после того, как был выбран элемент. Короче, внутри оно может и так работать. Я предлагаю тогда проверить сейчас, чтобы окончательно поставить вопрос, а не строить догадки.
l
вряд ли про разные в смысле rxjava vs reactor. они одинаково такой кейс обрабатывают
A
Ну а почему в доке черным по белому написано обратное?
l
а что здесь обратного? тут же написано что последние N элементов до oncomplete
l
даже картинка показывает то же самое
A
Так ты написал же про то, что метод берёт последний элемент после комплита. А N последних - это лишь сигнатура, к ней не надо привязываться. Вот, например, last (https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#last--):
>Emit the last element observed before complete signal as a Mono, or emit NoSuchElementException error if the source was empty.
Я не понимаю какая тут связь с картинкой, как раз на ней и показано, что оно берется ДО комплита.
>Emit the last element observed before complete signal as a Mono, or emit NoSuchElementException error if the source was empty.
Я не понимаю какая тут связь с картинкой, как раз на ней и показано, что оно берется ДО комплита.
l
элементы до комплита, но отсылаются после комплита
A
Как-то слишком запутанно.
l
и не говори. мы все страдаем)
2021 May 20
RC
Вопрос по RxJava
Ребят, а как использовать Single.zipArray/Single.zip(array, mapper)? У меня в маппер прилетает Object[], мне это надо руками кастовать или я что-то делаю не так? Все зипнутые синглы возвращают один и тот же тип данных
Ребят, а как использовать Single.zipArray/Single.zip(array, mapper)? У меня в маппер прилетает Object[], мне это надо руками кастовать или я что-то делаю не так? Все зипнутые синглы возвращают один и тот же тип данных
D
Здраствуйте у меня проблема с кодом дело в том что я использую библиотеки OPEN GL а именно GLFW...
Так вот у меня выдает такую ошибку что на строке 59 что-то неправильно(причину ошибки не показывают)
Так вот у меня выдает такую ошибку что на строке 59 что-то неправильно(причину ошибки не показывают)
И
Не совсем понятно при чем тут rx
D
Ну группа для джавы сказали