46 lines
1.4 KiB
Diff
46 lines
1.4 KiB
Diff
|
diff --git a/node_modules/protomux/index.js b/node_modules/protomux/index.js
|
||
|
|
index 07bf0ad..c8db59c 100644
|
||
|
|
--- a/node_modules/protomux/index.js
|
||
|
|
+++ b/node_modules/protomux/index.js
|
||
|
|
@@ -195,34 +195,34 @@ class Channel {
|
||
|
|
type,
|
||
|
|
encoding,
|
||
|
|
onmessage,
|
||
|
|
- recv (state, session) {
|
||
|
|
+ async recv (state, session) {
|
||
|
|
session._track(m.onmessage(encoding.decode(state), session))
|
||
|
|
},
|
||
|
|
- send (m, session = s) {
|
||
|
|
+ async send (m, session = s) {
|
||
|
|
if (session.closed === true) return false
|
||
|
|
|
||
|
|
const mux = session._mux
|
||
|
|
const state = { buffer: null, start: 0, end: typeLen }
|
||
|
|
|
||
|
|
if (mux._batch !== null) {
|
||
|
|
- encoding.preencode(state, m)
|
||
|
|
+ await encoding.preencode(state, m)
|
||
|
|
state.buffer = mux._alloc(state.end)
|
||
|
|
|
||
|
|
c.uint.encode(state, type)
|
||
|
|
- encoding.encode(state, m)
|
||
|
|
+ await encoding.encode(state, m)
|
||
|
|
|
||
|
|
mux._pushBatch(session._localId, state.buffer)
|
||
|
|
return true
|
||
|
|
}
|
||
|
|
|
||
|
|
c.uint.preencode(state, session._localId)
|
||
|
|
- encoding.preencode(state, m)
|
||
|
|
+ await encoding.preencode(state, m)
|
||
|
|
|
||
|
|
state.buffer = mux._alloc(state.end)
|
||
|
|
|
||
|
|
c.uint.encode(state, session._localId)
|
||
|
|
c.uint.encode(state, type)
|
||
|
|
- encoding.encode(state, m)
|
||
|
|
+ await encoding.encode(state, m)
|
||
|
|
|
||
|
|
mux.drained = mux.stream.write(state.buffer)
|
||
|
|
|