Nonconformist Propaganda Machine

    callbag-take
    TypeScript icon, indicating that this package has built-in type declarations

    1.5.0 • Public • Published

    callbag-take

    Callbag operator that limits the amount of data sent by a source. Works on either pullable and listenable sources.

    npm install callbag-take

    example

    On a listenable source:

    const interval = require('callbag-interval');
    const observe = require('callbag-observe');
    const take = require('callbag-take');
     
    const source = take(3)(interval(1000));
     
    source(0, observe(x => console.log(x))); // 0
                                             // 1
                                             // 2

    On a pullable source:

    const fromIter = require('callbag-from-iter');
    const iterate = require('callbag-iterate');
    const take = require('callbag-take');
     
    function* range(from, to) {
      let i = from;
      while (<= to) {
        yield i;
        i++;
      }
    }
     
    const source = take(4)(fromIter(range(100, 999)));
     
    source(0, iterate(x => console.log(x))); // 100
                                             // 101
                                             // 102
                                             // 103

    Keywords

    Install

    npm i callbag-take

    DownloadsWeekly Downloads

    1,579

    Version

    1.5.0

    License

    MIT

    Unpacked Size

    18.3 kB

    Total Files

    8

    Last publish

    Collaborators

    • staltz
    • zimme