index.js

const {Transform} = require('stream');
const RTMPServer = require('./server');

function createServer(options = {}) {
  return new RTMPServer(options);
}

function createSimpleServer(path, options = {}) {
  const transform = new Transform({objectMode: true});
  transform._transform = function (chunk, enc, cb) {
    this.push(chunk);
    cb();
  };
  const server = createServer(options)
  .once(path, connection => {
    connection.once('*', stream => {
      stream.pipe(transform);
    })
    .on('error', err => {
      transform.emit('error', err);
    });
  })
  .on('error', err => {
    transform.emit('error', err);
  });
  setImmediate(() => {
    transform.emit('__fook__', server);
  });
  return transform;
}

module.exports = {createServer, createSimpleServer};