Cacher is the code snippet organizer for pro developers

import processFile from 'file-processsor';
 
export default function(sb) {
  // Use plugin to bind sb methods
  let { { file: sendFile }, error, on } = sb
  
  return {
    init({ encode }) {
      on('new-file', async function(ch, file) {
        try {
          let processedFile = await processFile(file, encode);
          let result = await sendFile(processedFile);
          console.log(result);
        } catch (err) {
          error(err);
          throw err;
        }
      });
    }
  }
}

mediator.on(channel) => function (handler) => subscription
handler : function (channel, data, [next])

var processFile = require('file-processsor');
 
module.exports = function(sb) {
  return {
    init: function(options) {
      var sendFile   = sb.send('file'),
          error      = sb.emit('error');
      
      sb.on('new-file', async function (ch, file) {
        try {
          let processedFile = await processFile(file);
          let result = await sendFile(processedFile);
          console.log(result);
        } catch (err) {
          error(err);
          throw err;
        }
      });
    }
  }
}

var processFile = require('file-processsor');

module.exports = function(sb) {
  return {
    init: async function(options) {
      var newFiles = sb.on('new-file'),
          sendFile = sb.send('file'),
          error    = sb.emit('error');
      
      for (let file on newFiles) {
        try {
          let processedFile = await processFile(file);
          let result = await sendFile(processedFile);
          console.log(result);
        } catch (err) {
          error(err);
        }
      }
    }
  }
}

var processFile = require('file-processsor');

module.exports = function(sb) {
  return {
    init: function(options) {
      sb.on('new-file', function(ch, file, next) {
        processFile(file).then(function (processedFile) {
          sb.send('file', processedFile, function (err, result) {
            if (err) {
              sb.emit('error', err);
              return next(err);
            }
            console.log(result);
            next();
          });
        }).catch(function (err) {
          sb.emit('error', err);
          next(err);
        })
      });
    }
  }
}