Function fn

src/interop/to-es-observable.js:16–28

        : observerOrOnNext

    const fn = event => {
      if (event.type === END) {
        closed = true
      }

      if (event.type === VALUE && observer.next) {
        observer.next(event.value)
      } else if (event.type === ERROR && observer.error) {
        observer.error(event.value)
      } else if (event.type === END && observer.complete) {
        observer.complete(event.value)
      }
    }

    this._observable.onAny(fn)
    let closed = false