1 files changed, 31 insertions, 0 deletions
diff --git a/node_modules/webpack-serve/lib/bus.js b/node_modules/webpack-serve/lib/bus.js
new file mode 100644
index 00000000..57c834bc
--- /dev/null
+++ b/node_modules/webpack-serve/lib/bus.js
@@ -0,0 +1,31 @@
+const isPlainObject = require('lodash/isPlainObject');
+const nanobus = require('nanobus');
+const weblog = require('webpack-log');
+
+const WebpackServeError = require('./WebpackServeError');
+
+module.exports = (options) => {
+  const log = weblog({ name: 'serve', id: 'webpack-serve' });
+  const bus = nanobus();
+
+  if (isPlainObject(options.on)) {
+    for (const event of Object.keys(options.on)) {
+      const fn = options.on[event];
+
+      if (typeof fn === 'function') {
+        log.info(`Subscribed to '${event}' event`);
+        bus.on(event, fn);
+      } else {
+        throw new WebpackServeError(
+          `The value for an \`on\` event handler must be a Function. event: ${event}`
+        );
+      }
+    }
+  } else if (options.on) {
+    throw new WebpackServeError(
+      'The value for the `on` option must be an Object. Please see the README.'
+    );
+  }
+
+  return bus;
+};