Function createProviderProtocol

packages/protocols/src/provider.ts:28–53

(editor: Editor)

}

export const createProviderProtocol = (editor: Editor): ProviderProtocol => {
  const observable = new Observable<'connected' | 'disconnected'>()
  const providerProtocol = {
    connect: () => {
      if (providerProtocol.connected()) {
        throw new Error('already connected')
      }
      CONNECTED.add(editor)
      observable.emit('connected', [editor])
    },
    disconnect: () => {
      CONNECTED.delete(editor)
      observable.emit('disconnected', [editor])
    },
    connected: () => {
      return CONNECTED.has(editor)
    },
    on: (event: 'connected' | 'disconnected', handler: (editor: Editor) => void) => {
      observable.on(event, handler)
    },
    off: (event: 'connected' | 'disconnected', handler: (editor: Editor) => void) => {
      observable.off(event, handler)
    },
  }
  return providerProtocol
}

export const withProviderProtocol = (editor: Editor) => {
  let providerProtocol = PROVIDERS.get(editor)