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

Вопрос про метод fs2.Stream.merge(fs2.Stream) В документации указано The implementation always tries to

pull one chunk from each side before waiting for it to be consumed by the resulting stream.

Мердж забрал первый элемент и не дожидаясь пока этот элемент заберет результирующий стрим сразу пытается забрать ещё один?

Реализация этого метода не очень понятная, но из того, что я видел, из очереди забирается по одному чанку из каждого стрима.

1 ответов

4 просмотра

fs2 я не пользуюсь, но судя по описани: стоит на кассе в макдаке продавец, который продает только бургер и колу (мерджит), к нему стоит очередь из заказов, которые не вправе выбирать, что из этого они в итоге заберут (стрим же на выходе одного элемента). так вот, есть кто в очереди заказов или нет, этот продавец все равно кричит поварам, чтобы приготовили одну колу и один бургер и ставит их перед собой в мини-буфер-queue. И очередь заказов в итоге разбирает это в том порядке, в котором выставил продавец. При этом если продавец видит, что взяли бургер - он кричит, чтобы сделали еще бургер, если видит, что забрали колу - кричит, чтобы сделали еще колу и ему не важно есть ли еще заказы или нет, и будут ли вобще когда-нибудь

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

Обсуждают сегодня

коллеги, добрый вечер! А никто не знает как модальная форма может себя закрыть? Ну допустим модальная форма определила, что смысла ей работать нет и хочет вернуть modalResult...
Михаил
83
А если изначально бот работал так : есть сайт онлайн школы. У каждого ученика свой кабинет. Где он авторизуется по своим данным. И уже в кабинете, на самом сайте делает оплату...
Денис 💡 Фрилансер
13
А что ты вообще делаешь ?
Yesgoter
13
На работе пишем распределенное приложение, у которого сотни, если не тысячи настроек. Конфиги написаны на xml, расположены на разных хостах и должны быть согласованы друг с др...
Aleksandr Druzhinin
5
Всем привет 🙂 Какая-то непонятная проблема у меня с видео, раньше такого не было. Загружаю видео с гугл диска именно в видео mp4 и меняю ссылку как положено вот она: https://d...
Ксюша|Верстка на Тильде|Дизайн 🦥
6
средствами IBX как-то можно выполнить запрос insert ... returning?
Igor
31
Добрый день Хочу начать обучение языку, не являюсь представителем it, буду благодарна за помощь, совсем пока не понимаю ничего) Подскажите, пожалуйста, где можно начать первы...
Sara Lala
18
что это и почему оно? executor.start_polling(bot, skip_updates=True, on_startup=on_startup, File "/usr/local/lib/python3.10/dist-packages/aiogram/utils/executor.py", line 4...
𐌍𐌄 ᕓ𐌄𐌓𐌌Ꝋ𐌓𐌄
2
Hi there everyone Is there anyone who have not started hamster bot yet? I need only one, I'll be glad if you do this for me DM if you haven't yet
Mehrshad
53
Подскажите, почему в правом коде с1 дополняется до 8байт, а не до 4?
Sergey
9
Карта сайта