@niwinz are there some utils in beicon for creating streams from core.async channels? Or you think there’s no point in such abstraction? Currently I’m crafting such streams by hand and started pondering 🙂
@dhucerbin not, for this moment... it will imply have core.async dependency and I don't want add more dependencies to the library. Adapting core.async channels to streams or strams to channels is straightforward so I think it can be done on client code
Good point. So just use rx/create
, and pass rx/end
when channel returns nil? Anyway, thanks for such nifty library.
Thanks! And yes, rx/create seems adecuate for this case