Ну, я нашел проблему. Я думаю, StreamZip
ждет, пока все потоки не испустят один раз, а затем запустит функцию сборкиЯ думаю, что я должен использовать что-то вроде Observable.merge
или StreamGroup.merge
, но у меня тоже есть проблема с этим, и немного сложно справиться с этим. Так что сейчас я использую два вложенных StreamBuilder
с, и он отлично работает