Module `Dream_pure.Message`Source

Sourcetype client

Sourcetype server

Sourcetype 'a message

Sourcetype request = client message

Sourcetype response = server message

Sourcetype 'a promise = 'a Lwt.t

Sourcetype handler = request -> response promise

Sourcetype middleware = handler -> handler

Source

val request : 
  ?method_:[< Method.method_ ] ->
  ?target:string ->
  ?headers:(string * string) list ->
  Stream.stream ->
  Stream.stream ->
  request

Sourceval method_ : request -> Method.method_

Sourceval target : request -> string

Sourceval set_method_ : request -> [< Method.method_ ] -> unit

Sourceval set_target : request -> string -> unit

Source

val response : 
  ?status:[< Status.status ] ->
  ?code:int ->
  ?headers:(string * string) list ->
  Stream.stream ->
  Stream.stream ->
  response

Sourceval status : response -> Status.status

Sourceval set_status : response -> Status.status -> unit

Sourceval header : 'a message -> string -> string option

Sourceval headers : 'a message -> string -> string list

Sourceval all_headers : 'a message -> (string * string) list

Sourceval has_header : 'a message -> string -> bool

Sourceval add_header : 'a message -> string -> string -> unit

Sourceval drop_header : 'a message -> string -> unit

Sourceval set_header : 'a message -> string -> string -> unit

Sourceval set_all_headers : 'a message -> (string * string) list -> unit

Sourceval sort_headers : (string * string) list -> (string * string) list

Sourceval lowercase_headers : 'a message -> unit

Sourceval body : 'a message -> string promise

Sourceval set_body : 'a message -> string -> unit

Sourceval set_content_length_headers : 'a message -> unit

Sourceval drop_content_length_headers : 'a message -> unit

Sourceval read : Stream.stream -> string option promise

Sourceval write : Stream.stream -> string -> unit promise

Sourceval flush : Stream.stream -> unit promise

Sourceval close : Stream.stream -> unit promise

Sourceval client_stream : 'a message -> Stream.stream

Sourceval server_stream : 'a message -> Stream.stream

Sourceval set_client_stream : 'a message -> Stream.stream -> unit

Sourceval set_server_stream : 'a message -> Stream.stream -> unit

Sourceval create_websocket : response -> Stream.stream * Stream.stream

Sourceval get_websocket : response -> (Stream.stream * Stream.stream) option

Source

val close_websocket : 
  ?code:int ->
  (Stream.stream * Stream.stream) ->
  unit promise

Sourcetype text_or_binary = [

| `Text
| `Binary

]

Sourcetype end_of_message = [

| `End_of_message
| `Continues

]

Sourceval receive : Stream.stream -> string option promise

Source

val receive_fragment : 
  Stream.stream ->
  (string * text_or_binary * end_of_message) option promise

Source

val send : 
  ?text_or_binary:[< text_or_binary ] ->
  ?end_of_message:[< end_of_message ] ->
  Stream.stream ->
  string ->
  unit promise

Sourceval no_middleware : middleware

Sourceval pipeline : middleware list -> middleware

Sourcetype 'a field

Sourceval new_field : ?name:string -> ?show_value:('a -> string) -> unit -> 'a field

Sourceval field : 'b message -> 'a field -> 'a option

Sourceval set_field : 'b message -> 'a field -> 'a -> unit

Sourceval fold_fields : (string -> string -> 'a -> 'a) -> 'a -> 'b message -> 'a

package dream-pure

Module Dream_pure.MessageSource

Module `Dream_pure.Message`Source