lib/replicate.js
function () {
    var write = function (node, enc, cb) {
      node.value = encoder.encode(node.value, dag.valueEncoding)
      stream.node(node, cb)
    }

    stream.emit('live')
    pipe(dag.createReadStream({since: changes, live: true}), through.obj(write))
  }
function () {
    var write = function (node, enc, cb) {
      node.value = encoder.encode(node.value, dag.valueEncoding)
      stream.node(node, cb)
    }

    stream.emit('live')
    pipe(dag.createReadStream({since: changes, live: true}), through.obj(write))
  }
function ( ) { var write = function ( node , enc , cb ) { node . value = encoder . encode ( node . value , dag . valueEncoding ) stream . node ( node , cb ) } stream . emit ( 'live' ) pipe ( dag . createReadStream ( { since : changes , live : true } ) , through . obj ( write ) ) }
For live replication. Reads live from the local hyperlog and continues to send new nodes to the other end.
For live replication . Reads live from the local hyperlog and continues to send new nodes to the other end .