replikativ.connect
Connection management middleware.
connect
(connect [S peer [in out]])
handle-connection-request
(handle-connection-request S peer conn-ch out)
Service connection requests. Waits for ack on initial subscription, also ensuring you have the remote state of your subscriptions locally replicated.
handshake-middleware
(handshake-middleware url id subs extend? out [S peer [c-in c-out]])