Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- function createNode (inputObservable, { mapFn = v => v } = {}) {
- let listenerComplete = () => {};
- let subscription = {};
- const outputObservable = {
- map (fn) {
- return createNode(this, {
- mapFn: fn
- });
- },
- subscribe ({ next, complete }) {
- listenerComplete = complete;
- subscription = inputObservable.subscribe({
- next (val) {
- next(mapFn(val));
- },
- complete
- });
- return subscription;
- },
- complete () {
- subscription.unsubscribe();
- listenerComplete();
- }
- };
- return outputObservable;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement