Other systems exists which bring this old approach back to where it should me,such as:
- NoFlo <noflojs.org> (Javascript implementation of FBP taking the world by storm)
- Goflow (Golang version of FBP)
- Microflo <http://www.jonnor.com/2013/11/microflo-0-2-0-visual-arduino-programming/>

//repeaters take and give what they recieve
var repeater = Repeater.create();
//prefixer takes an input and prefix a value it receives from its option stream to the input value
var prefixer = StringPrefixer.create();

//you can rename ports names
repeater.renamePort('in','suck');
repeater.renamePort('out','spill');

//basic creation of ports,used internally by components
var feeder  = Port.create('feeder');
var reader  = Port.create('writer');
var feeder2  = Port.create('feeder');

//usually ports are to be bounded to other ports but to peek into the stream
//of a port,simply tap into it
reader.tap((n){ print('#log  => $n'); });

//standard method of binding/connecting to ports to each other
feeder.bindPort(repeater.port('suck')); //connect feeder's to reader suck port
repeater.port('spill').bindPort(reader); //connect repeater's spill port to reader


feeder2.bindPort(prefixer.port('in'));
prefixer.port('out').bindPort(reader);

//send data to all connected ports of feeder
feeder.send('alex');
feeder.send('i need salt!');

//In FBP,there is a notion of substreams,which can be anchored by specific tags
// here the feeder is pushing a substream of article tag: 
// <article>1: road</article>
//begins the substream
feeder.beginGroup('<article>');
//data in the substream,can be called countless times to add data into the grouping
feeder.send('1: road');
//ends the substream
feeder.endGroup('</article>');

//without the option port recieving input the prefixer will buffer its streams,
//that is,the option port serves as a means of parsing options to the component or port
//like a value passed to a function call
prefixer.port('option').send('number:');

feeder2.send('1');
feeder2.send('2');

//this can be called over again to change the prefixed value
prefixer.port('option').send('tag:');

feeder2.send('4');

var rep1 = Repeater.create();
var rep2 = StringPrefixer.create();
var cosmo = Component.create('cosmo');

//lets loop cosmo in port to its outport,a basic repeater 

cosmo.loopPorts('in','out');

var network = Network.create("testBed");

network.add(rep1,'repeater',(meta){
  //print('internal initial socket: ${meta.toString().split(',').join('\n')}');
});
  
network.add(rep2,'prefixer',(meta){
  //print('internal initial socket: ${meta.toString().split(',').join('\n')}');

  //attach the IIP to the component's option port
  meta.socket.attachPort(meta.component.port('option'));
});

network.add(cosmo,'cosmo',(meta){
  //print('internal initial socket: ${meta.toString().split(',').join('\n')}');
});

/*order goes:
  1: component who wants to connect
  2: port name of component who wants to connect
  3: component to be connected to
  4: port name of component to be connected to
Optional:
  5: a tag name to be giving the socket,incase of selective message eg. send('data','1' or 'goba');
  6: bool value to dictate it uses breadthfirst search technique instead of the default depthfirst
*/
//prefixer wants to connect its 'in' port to repeaters 'out'
//repeater wants to connect its 'out' port to cosmo 'in' port;;
//needed due to the nature of network connections using futures

network
.connect('prefixer','in','repeater','out')
.connect('repeater','in','cosmo','out',null,true).whenConnectionCompletes((_){

  //its not always necessary for a networks in and outports to be connect,but there are cases eg composite components
  //where data must be fed into the network for its components to process
  
  //we will connect networks in port (nin) to cosmo 'in' port
  network.nin.bindPort(cosmo.port('in'));
  // tap into networks out port 'nout' to see what comes out

  network.nout.tap((n){
    print('network spouting: $n');
  });

  //only the prefixer component requires data feed into it before its operational,so add a IIP data for it,
  //you can always add another iip data to change the prefix;
  network.addInitial('prefixer','network::');


  // cosmo.port('in').tap((n){
  //  print('cosmo in: $n');
  // });

  // cosmo.port('out').tap((n){
  //  print('cosmo out: $n');
  // });

  // rep1.port('in').tap((n){
  //  print('repeater in: $n');
  // });

  // rep1.port('out').tap((n){
  //  print('repeater out: $n');
  // });

  // rep2.port('in').tap((n){
  //  print('prefixer in: $n');
  // });

  // rep2.port('out').tap((n){
  //  print('prefixer out: $n');
  // });

  network.nin.send('sanction'); 

  rep2.port('out').bindPort(network.nout);

  network.boot();
},(e){
  throws e;
});