tower-topology

0.1.0 • Public • Published

Tower Topology

Installation

node.js:

npm install tower-topology

browser:

component install tower-topology

Example

var topology = require('tower-topology')
  , stream = require('tower-stream');

stream('word-emitter')
  .on('init', function(node){
    node.words = [
        'hello'
      , 'hello'
      , 'hello'
      , 'hello'
      , 'hello'
      , 'world'
      , 'world'
    ];
  })
  .on('execute', function(node, data){
    if (node.words.length)
      node.emit('data', { word: node.words.shift() });
    else
      node.close();
  });

// b
stream('word-counter')
  .on('init', function(node){
    node.words = {};
  })
  .on('execute', function(node, data){
    null == node.words[data.word]
      ? node.words[data.word] = 1
      : ++node.words[data.word];

    node.emit('data', {
        word: data.word
      , count: node.words[data.word]
    });
  });

// topology
topology('word-count')
  .stream('word-emitter')
  .stream('word-counter')
    .input('word-emitter');

// this will happen internally
var count = topology('word-count').create()
  , counts = [];

// test
count
  .on('data', function(data){
    counts.push(data);
  })
  .on('close', function(){
    assert(7 === counts.length);

    assert('hello' === counts[0].word);
    assert(1 === counts[0].count);
    assert('hello' === counts[4].word);
    assert(5 === counts[4].count);

    assert('world' === counts[5].word);
    assert(1 === counts[5].count);
    assert('world' === counts[6].word);
    assert(2 === counts[6].count);
  }).execute();

Licence

MIT

Readme

Keywords

none

Package Sidebar

Install

npm i tower-topology

Weekly Downloads

0

Version

0.1.0

License

none

Last publish

Collaborators

  • viatropos