Skip to content

Commit 4249b7f

Browse files
add dist folder
1 parent fedc92a commit 4249b7f

14 files changed

+2592
-1
lines changed

.gitignore

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
dist/
21
node_modules/
32
example/
43
.vscode/

dist/Bus.js

Lines changed: 70 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,70 @@
1+
Object.defineProperty(exports, "__esModule", {
2+
value: true
3+
});
4+
exports.default = void 0;
5+
6+
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
7+
8+
function _defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } }
9+
10+
function _createClass(Constructor, protoProps, staticProps) { if (protoProps) _defineProperties(Constructor.prototype, protoProps); if (staticProps) _defineProperties(Constructor, staticProps); return Constructor; }
11+
12+
var Bus = function () {
13+
function Bus(send) {
14+
_classCallCheck(this, Bus);
15+
16+
this._paused = false;
17+
this._messageListeners = {};
18+
this._queue = [];
19+
this._send = send;
20+
}
21+
22+
_createClass(Bus, [{
23+
key: "post",
24+
value: function post(message) {
25+
var _this = this;
26+
27+
return new Promise(function (resolve) {
28+
if (message.type !== 'set') {
29+
_this._messageListeners[message.id] = resolve;
30+
}
31+
32+
if (!_this._paused) {
33+
_this._send(message);
34+
} else {
35+
_this._queue.push(message);
36+
}
37+
});
38+
}
39+
}, {
40+
key: "handle",
41+
value: function handle(message) {
42+
var handler = this._messageListeners[message.id];
43+
delete this._messageListeners[message.id];
44+
45+
if (handler) {
46+
handler(message);
47+
} else {
48+
console.warn('Received unexpected message', message);
49+
}
50+
}
51+
}, {
52+
key: "pause",
53+
value: function pause() {
54+
this._paused = true;
55+
}
56+
}, {
57+
key: "resume",
58+
value: function resume() {
59+
this._paused = false;
60+
61+
this._send(this._queue);
62+
63+
this._queue = [];
64+
}
65+
}]);
66+
67+
return Bus;
68+
}();
69+
70+
exports.default = Bus;

0 commit comments

Comments
 (0)