(event)
| 125 | : observerOrOnValue |
| 126 | |
| 127 | const handler = function(event) { |
| 128 | if (event.type === END) { |
| 129 | closed = true |
| 130 | } |
| 131 | if (event.type === VALUE && observer.value) { |
| 132 | observer.value(event.value) |
| 133 | } else if (event.type === ERROR && observer.error) { |
| 134 | observer.error(event.value) |
| 135 | } else if (event.type === END && observer.end) { |
| 136 | observer.end(event.value) |
| 137 | } |
| 138 | } |
| 139 | |
| 140 | this.onAny(handler) |
| 141 |