package subscriptions-transport-ws

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
module type SubscriptionsManager = sig ... end
module SubscriptionsManager : sig ... end
type 'a handlers = {
  1. schedule : 'a -> on_recv:((Yojson.Basic.t, Yojson.Basic.t) result -> unit) -> on_close:(unit -> unit) -> unit;
  2. destroy : 'a -> unit;
}
val on_recv : 't SubscriptionsManager.t -> subscribe: (variables:Graphql.Schema.variables -> ?operation_name:string -> string -> (([< `Response of Yojson.Basic.t | `Stream of 'a ], Yojson.Basic.t) result -> unit) -> unit) -> 'a handlers -> Websocketaf.Wsd.t -> opcode:Websocketaf.Websocket.Opcode.t -> is_fin:bool -> Bigstringaf.t -> off:int -> len:int -> unit