Function onCatch

lib/internal/streams/operators.js:72–75

()

    let cnt = 0;

    function onCatch() {
      done = true;
      afterItemProcessed();
    }

    function afterItemProcessed() {
      cnt -= 1;