//
// create a new cache
//
var tc = require('through-cache')()
 
a.pipe(tc.cache(function(obj) {
    
    //
    // this only gets called once because
    // the exact same data is written again.
    //
    // but two writes are made to the `b` stream,
    // one from the `a` stream and one from the 
    // cache.
    //
 
    var str = '<div>' + obj.value + '</div>'
    this.push(str)
 
}).pipe(b)
 
stream.write({ value: 'hello, world' })
stream.write({ value: 'hello, world' })

a.pipe(tc.cache(function(obj) {
 
    // the transform function will get cached and then 
    // applied to the data every time data gets pushed 
    // to the stream.
 
    this.transform(function(data) {
        return '<div>' + data + '</div>'
    })
 
    this.push(obj.value)
 
}).pipe(b)