diff options
| author | Adelyn Breelove <[email protected]> | 2018-12-12 15:23:14 -0700 |
|---|---|---|
| committer | Adelyn Breelove <[email protected]> | 2018-12-12 15:23:14 -0700 |
| commit | c046760eb599e42226c683aecbe33753dfc4d500 (patch) | |
| tree | 69b2be155e7dfc52710cb5b7700c31fab633896c /lib/sharder.ml | |
| parent | Work on event dispatch and add model derives (diff) | |
| download | disml-c046760eb599e42226c683aecbe33753dfc4d500.tar.xz disml-c046760eb599e42226c683aecbe33753dfc4d500.zip | |
Complete event dispatch
Diffstat (limited to 'lib/sharder.ml')
| -rw-r--r-- | lib/sharder.ml | 5 |
1 files changed, 3 insertions, 2 deletions
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; |