var TunnelStream = require('tunnel-stream');
 
var tunnel = new TunnelStream();
 
tunnel.downstream.setEncoding('utf8');
tunnel.upstream.setEncoding('utf8');
 
tunnel.downstream.on('data', function(data) {
  tunnel.downstream.write('hello, upstream');
});
 
tunnel.downstream.on('end', function(data) {
  // ended
});
 
tunnel.upstream.on('data', function(data) {
  tunnel.upstream.end('goodbye, downstream');
});
 
tunnel.upstream.on('end', function(data) {
  // ended
});
 
tunnel.upstream.write('hello, downstream');

var tunnel = new TunnelStream();
 
tunnel.downstream.setEncoding('utf8');
 
tunnel.downstream.on('data', function(data) {
  // should only receive the 'after discarded' message here
});
 
tunnel.downstream.on('pausedData', function(data) {
  // should receive the 'to be discarded' message here
 
  tunnel.downstream.discardBufferedEvents();
  tunnel.downstream.resume();
});
 
tunnel.downstream.pause();
 
tunnel.upstream.write('to be discarded');
tunnel.upstream.write('after discarded');

var tunnel = new TunnelStream({
  messageSize: 5
});
 
tunnel.downstream.setEncoding('utf8');
tunnel.downstream.on('data', function(data) {
  /* 
    should receieve the following messages
 
      'This '
      'is a '
      'testT'
      'his i'
      's als'
      'o a t'
      'estok'
      ' that'
      ' is a'
      'll'
  */
});
tunnel.downstream.on('end', function() {
  // finished
});
 
tunnel.upstream.write('This is a test');
tunnel.upstream.write('This is also a test');
tunnel.upstream.end('ok that is all'); // ending the connection will flush the last few bytes
 
// it is also possible to flush the last few bytes from the tunnel without ending the stream
// by calling the flush method, eg...
tunnel.upstream.flush();