diff --git a/node_modules/protomux/index.js b/node_modules/protomux/index.js
index 07bf0ad..ef91c72 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)
 
@@ -417,7 +417,7 @@ module.exports = class Protomux {
 
   _ondata (buffer) {
     try {
-      const state = { buffer, start: 0, end: buffer.byteLength }
+      const state = { buffer, start: 0, end: buffer.buffer.byteLength }
       this._decode(c.uint.decode(state), state)
     } catch (err) {
       this._safeDestroy(err)