From c046760eb599e42226c683aecbe33753dfc4d500 Mon Sep 17 00:00:00 2001
From: Adelyn Breelove <tenseiken595@gmail.com>
Date: Wed, 12 Dec 2018 15:23:14 -0700
Subject: Complete event dispatch

---
 lib/sharder.ml | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'lib/sharder.ml')

diff --git a/lib/sharder.ml b/lib/sharder.ml
index b1f5d62..e28a306 100644
--- a/lib/sharder.ml
+++ b/lib/sharder.ml
@@ -1,4 +1,4 @@
-module Make(H: S.Http) = struct
+module Make(H: S.Http)(D : S.Dispatch) = struct
     open Async
     open Core
     open Websocket_async
@@ -68,8 +68,9 @@ module Make(H: S.Http) = struct
             let data = J.member "d" payload in
             let session = J.(member "session_id" data |> to_string_option) in
             if t = "READY" then begin
-                Ivar.fill_if_empty shard.ready ();
+                Ivar.fill_if_empty shard.ready ()
             end;
+            D.dispatch ~ev:t data;
             return { shard with
                 seq = seq;
                 session = session;
-- 
cgit v1.2.3