chore: accept timeout option for createMapeoClient() (#6)

digidem · Feb 1, 2024 · 8dfca00 · 8dfca00
1 parent d25dff5
commit 8dfca00
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/client.js b/src/client.js
@@ -25,19 +25,22 @@ const CLOSE = Symbol('close')
 
 /**
  * @param {import('./lib/sub-channel.js').MessagePortLike} messagePort
+ * @param {object} [opts]
+ * @param {number} [opts.timeout]
+ *
  * @returns {MapeoClientApi}
  */
-export function createMapeoClient(messagePort) {
+export function createMapeoClient(messagePort, opts = {}) {
   /** @type {Map<string, Promise<import('rpc-reflector/client.js').ClientApi<import('@mapeo/core/dist/mapeo-project.js').MapeoProject>>>} */
   const projectClientPromises = new Map()
 
   const managerChannel = new SubChannel(messagePort, MANAGER_CHANNEL_ID)
   const mapeoRpcChannel = new SubChannel(messagePort, MAPEO_RPC_ID)
 
   /** @type {import('rpc-reflector').ClientApi<import('@mapeo/core').MapeoManager>} */
-  const managerClient = createClient(managerChannel)
+  const managerClient = createClient(managerChannel, opts)
   /** @type {import('rpc-reflector').ClientApi<import('./server.js').MapeoRpcApi>} */
-  const mapeoRpcClient = createClient(mapeoRpcChannel)
+  const mapeoRpcClient = createClient(mapeoRpcChannel, opts)
 
   mapeoRpcChannel.start()
   managerChannel.start()