Касательно полноценной потоковой библиотеки (а-ля Java).
Я конечно гораздо меньше в этом разбираюсь, но мне кажется, что здесь лучше использовать общую джулия парадигму о том, что не надо делать огромные пакеты, которые умеют делать всё на свете. Лучше иметь несколько хороших маленьких пакетов, каждый из которых делает что-то своё, но делает это хорошо.
Например - читать откуда-то, обрабатывать и куда-то писать. Насколько я понимаю, Rocket.jl даёт интерфейс для работы c Observable, но ему самому нет в общем-то дела до того, откуда эти Observable наполняются. Поэтому это вполне может быть другая библиотека, которая например умеет читать из кафки или откуда-то ещё. На функциональность собственно реактивного фреймворка это никак влиять не должно.