forked from crcn/mesh.js
-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.js
53 lines (42 loc) · 1.41 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
module.exports = {
/**
* busses
*/
Bus : require('./bus/base'),
MapBus : require('./bus/map'),
NoopBus : require('./bus/noop'),
WrapBus : require('./bus/wrap'),
RaceBus : require('./bus/race'),
RetryBus : require('./bus/retry'),
RandomBus : require('./bus/random'),
AcceptBus : require('./bus/accept'),
RejectBus : require('./bus/reject'),
DelayedBus : require('./bus/delayed'),
SequenceBus : require('./bus/sequence'),
ParallelBus : require('./bus/parallel'),
BufferedBus : require('./bus/buffered'),
FallbackBus : require('./bus/fallback'),
CatchErrorBus : require('./bus/catch-error'),
RoundRobinBus : require('./bus/round-robin'),
AttachDefaultsBus : require('./bus/attach-defaults'),
// TODO
// ReduceBus:require('./bus/reduce'),
/**
* responses
*/
Response : require('./response'),
EmptyResponse : require('./response/empty'),
ErrorResponse : require('./response/error'),
BufferedResponse : require('./response/buffered'),
NodeStreamResponse : require('./response/node-stream'),
/**
*/
WritableStream : require('./stream/writable')
};
if (typeof window !== 'undefined') {
module.exports.noConflict = function() {
delete window.mesh;
return module.exports;
};
window.mesh = module.exports;
}