multilevel-readstream-error.js

'use strict';

var net = require('net');
var multilevel = require('multilevel');
var level = require('level');

var db = level('db');

var server = net.createServer(con => {
  con.pipe(multilevel.server(db, {
    access() {
      throw new Error('unauthorized');
    }
  })).pipe(con);
});

server.listen(3000, () => {
  let db = multilevel.client();
  let con = net.connect(3000);
  con.pipe(db.createRpcStream()).pipe(con);
  db.createReadStream()
    .on('error', err => console.log('Error!', err.message))
    .on('data', d => console.log('Data', d))
    .on('end', () => console.log('End'));
});