If that's too heavy handed, you should be able to ...

# rx

[alexsullivan114]

If that's too heavy handed, you should be able to use Observable.create to emit items as they stream instead of waiting for all of the items to be ready.