code: 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))
    }
docs: For live replication. Reads live from the local hyperlog and continues to send new nodes to the other end.