bottling

[dcharbonnier]

AKA json-streaming with filter

[kmannislands]

Would this be required to use it with ShareDB on the server?
Trying to understand how this fits in with WebSocketJSONStream. Client API makes sense but I don't get how to put a pipe in front of ShareDB on the server.

[kmannislands]

Figured it out. My issue was actually #101

For future readers (if the interface hasn't been fixed in the library), to work with ShareDB on the server, the following did the trick for me:

import { Pipe } from 'hydrated-ws'

// the sole purpose of this is to patch the interface
class EmitterPipe extends Pipe {
  on(event, cb) {
    return this.addEventListener(event, (msg) => cb(msg.data));
  }
}

const wss = new WebSocket.Server();

wss.on('connection', (ws) => {
  const ShareDBChannel = new EmitterPipe(ws, 'SDB');
  const stream = new WebSocketJSONStream(ShareDBChannel);
  this.share.listen(stream);
});

When the fix for #101 lands, sounds like the patch class won't be necessary and when bottling lands, the WebSocketJSONStream won't be necessary either.