Function handleOpen

lib/src/websockets.ts:22–27

(store: Store)

}

function handleOpen(store: Store) {
  // TODO: Add a way to subscribe to multiple resources in one request
  for (const subject of store.subscribers.keys()) {
    store.subscribeWebSocket(subject);
  }
}

function handleMessage(ev: MessageEvent, store: Store) {
  if (ev.data.startsWith('COMMIT ')) {