package graphql-async

  1. Overview
  2. Docs

Source file graphql_async.ml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
module Schema = Graphql_schema.Make (struct
  include Async_kernel.Deferred

  let bind x f = bind x ~f

  module Stream = struct
    type 'a t = 'a Async_kernel.Pipe.Reader.t

    let map t f = Async_kernel.Pipe.map' t ~f:(fun q ->
      Async_kernel.Deferred.Queue.map q ~f)

    let iter t f = Async_kernel.Pipe.iter t ~f

    let close = Async_kernel.Pipe.close_read
  end
end) (struct
  type t = string
  let message_of_field_error t = t
  let extensions_of_field_error _t = None
end)