session.ml

open Core.Std
open Async.Std

type chunk = String of string | Bigstring of Bigstring.t

type sink = Bigstring.t option -> unit Deferred.t
type source = unit -> chunk option Deferred.t

type handler =
  { init: Session.t -> [`Drop | `Accept of sink | `Forget ] Deferred.t
  ; handle: Session.t -> Response.t * source }