new Emitter({
run(me){
me.send(1)
me.send(2)
me.send(3)
me.resolve()
}
})
new Observable((next, error, complete, signal) => {
next(1);
next(2);
next(3);
complete();
});
new Emitter({
run(me){
me.send(1)
me.send(2)
me.send(3)
me.resolve()
}
})
new Observable((next, error, complete, signal) => {
next(1);
next(2);
next(3);
complete();
});