Skip to content

Commit

Permalink
replace node's built in events
Browse files Browse the repository at this point in the history
  • Loading branch information
monteslu committed Sep 24, 2024
1 parent 04e865f commit 24f81a1
Show file tree
Hide file tree
Showing 12 changed files with 308 additions and 493 deletions.
773 changes: 293 additions & 480 deletions dist/bundle.js

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion index.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');
const transports = require('./transports');

function rawr({ transport, timeout = 0, handlers = {}, methods, idGenerator }) {
Expand Down
8 changes: 5 additions & 3 deletions package.json
Original file line number Diff line number Diff line change
@@ -1,8 +1,10 @@
{
"name": "rawr",
"version": "0.16.0",
"description": "JSON-RPC over simple event emitters",
"dependencies": {},
"version": "0.17.0",
"description": "JSON-RPC over simple node style event emitters",
"dependencies": {
"eventemitter3": "^5.0.1"
},
"devDependencies": {
"b64id": "^1.0.1",
"browserify": "^16.2.3",
Expand Down
2 changes: 1 addition & 1 deletion test/index.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const chai = require('chai');
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');
const b64id = require('b64id');
const rawr = require('../');

Expand Down
2 changes: 1 addition & 1 deletion test/mqtt_transport.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const chai = require('chai');
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');
const rawr = require('../');

chai.should();
Expand Down
2 changes: 1 addition & 1 deletion test/socketio_transport.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const chai = require('chai');
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');
const rawr = require('../');

chai.should();
Expand Down
2 changes: 1 addition & 1 deletion test/websocket_transport.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const chai = require('chai');
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');
const rawr = require('../');

chai.should();
Expand Down
2 changes: 1 addition & 1 deletion test/worker_transport.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const chai = require('chai');
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');
const rawr = require('../');

chai.should();
Expand Down
2 changes: 1 addition & 1 deletion transports/mqtt/index.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');

function transport({ connection, subTopic, pubTopic, subscribe = true }) {
const emitter = new EventEmitter();
Expand Down
2 changes: 1 addition & 1 deletion transports/socketio/index.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');

function transport({ connection, subTopic, pubTopic }) {
const emitter = new EventEmitter();
Expand Down
2 changes: 1 addition & 1 deletion transports/websocket/index.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');

function transport(socket, allowBinary = false) {
const emitter = new EventEmitter();
Expand Down
2 changes: 1 addition & 1 deletion transports/worker/index.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
const { EventEmitter } = require('events');
const EventEmitter = require('eventemitter3');

function dom(webWorker) {
const emitter = new EventEmitter();
Expand Down

0 comments on commit 24f81a1

Please sign in to comment.