Function next

operators/src/toggleMap.ts:35–47

(trigger)

      return source.subscribe({
        next(trigger) {
          if (!innerSub || innerSub.closed) {
            innerSub = from(workCreator(trigger)).subscribe({
              next: (inner) => {
                const result = (mapper ? mapper(trigger, inner) : inner) as S;
                notify.next(result);
              },
              error: (e) => notify.error(e),
            });
          } else {
            innerSub.unsubscribe();
          }
        },
        error(e) {
          notify.error(e);
        },