From 193cd616263306c5ac21dc8b93dfd91a335a0c8b Mon Sep 17 00:00:00 2001 From: Adelyn Breelove Date: Tue, 29 Jan 2019 13:27:18 -0700 Subject: Compression!!! --- lib/sharder.mli | 1 + 1 file changed, 1 insertion(+) (limited to 'lib/sharder.mli') diff --git a/lib/sharder.mli b/lib/sharder.mli index 92c4178..5017a86 100644 --- a/lib/sharder.mli +++ b/lib/sharder.mli @@ -20,6 +20,7 @@ module Shard : sig (** Representation of the state of a shard. *) type shard = { hb_interval: Time.Span.t Ivar.t; (** Time span between heartbeats, wrapped in an Ivar. *) + hb_stopper: unit Ivar.t; (** Stops the heartbeat sequencer when filled. *) seq: int; (** Current sequence number *) session: string option; (** Session id, if one exists. *) pipe: Frame.t Pipe.Reader.t * Frame.t Pipe.Writer.t; (** Raw frame IO pipe used for websocket communications. *) -- cgit v1.2.3