terminator

inform an iterable when it is prematurely terminated by the consumer.

Install

yarn add @async-generators/terminator

This package's main entry points to a commonjs dist. The module entry points to a es2015 module dist. Both require require native async-generator support, or be down-compiled with a webpack loader.

Api

terminator(source)

terminator() returns an iterable that, when iterated, wraps the source iterable and captures calls to return. When a compliant consumer (for, for-await) terminates iteration, then the return call is rerouted to call next(Symbol.for("terminated")). The original source iterable can then find out if it was terminated by examining the return value of yield to see if it equals Symbol.for("terminated");

source must have a [Symbol.asyncIterator] or [Symbol.iterator] property. If both are present only [Symbol.asyncIterator] is used.

Example

example.js

const terminator = require("@async-generators/terminator").default;

async function* source() {
  for (let i = 0; i < 10; i++) {
    let terminated = (yield i) == Symbol.for("terminated");
    if (terminated) {
      console.log("clean-up on aisle five!");
      return;
    }
  }
}

async function main(){
  for await (let item of terminator(source())){
    if(item > 4){
      break;
    }
    console.log(item);
  }
}

main().catch(console.log);

Execute with the latest node.js:

node --harmony-async-iteration example.js

output:

0
1
2
3
4
clean-up on aisle five!

Typescript

This library is fully typed and can be imported using:

import terminator from '@async-generators/terminator');

It is also possible to directly execute your properly configured typescript with ts-node:

ts-node --harmony_async_iteration example.ts