Module `Devkit_core.Async`Source

Asynchronous IO helpers

module Ev = Libevent

Sourcemodule Internal : sig ... end

val simple_event : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  Unix.file_descr ->
  Ev.event_flags list ->
  (Ev.event -> Unix.file_descr -> Ev.event_flags -> unit) ->
  Ev.event

Create a new event or use the provided ev and make it persistent with the infinite timeout (or use the provided timeout). Schedule this event with provided callback f. Don't forget del to unschedule.

Source

val setup_simple_event : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  Unix.file_descr ->
  Ev.event_flags list ->
  (Ev.event -> Unix.file_descr -> Ev.event_flags -> unit) ->
  unit

Sourcetype result =

| End
| Data of int
| Block
| Exn of exn

Sourceval read_some : Unix.file_descr -> bytes -> int -> int -> result

Sourceval write_some : Unix.file_descr -> string -> int -> int -> int

Source

val read_available : 
  limit:int ->
  Unix.file_descr ->
  [> `Chunk of string * bool | `Limit of string ]

Read out all immediately available input (no blocking)

returns
`Limit when limit is exceeded, `Chunk (data,final) otherwise

Source

val show_error : 
  [< `Eof | `EofImm | `Exn of exn | `ExnImm of exn | `Timeout ] ->
  string

Source

val read_buf : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  bytes ->
  Unix.file_descr ->
  ([> `Eof | `EofImm | `Exn of exn | `ExnImm of exn | `Timeout ] ->
    int ->
    unit) ->
  (bytes -> unit) ->
  unit

read_buf buf fd err k - asynchronously fill buf with data from fd and call k buf when done (buffer is full). fd should be nonblocking. Call err on error (EOF).

Source

val read_n : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  int ->
  Unix.file_descr ->
  ([> `Eof | `EofImm | `Exn of exn | `ExnImm of exn | `Timeout ] ->
    int ->
    unit) ->
  (string -> unit) ->
  unit

Source

val periodic_timer_0 : 
  Ev.event_base ->
  bool ref ->
  float ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  Ev.event

Call f with delay-second pauses between invocations. Set stop to true to stop the timer. NB do not Ev.del the event inside the f callback.

Source

val periodic_timer_now : 
  Ev.event_base ->
  ?stop:bool ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  Ev.event

Source

val periodic_timer_wait : 
  Ev.event_base ->
  ?stop:bool ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  Ev.event

Source

val setup_periodic_timer_now : 
  Ev.event_base ->
  ?stop:bool ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  unit

Source

val setup_periodic_timer_wait : 
  Ev.event_base ->
  ?stop:bool ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  unit

Sourcemodule Peer : sig ... end

Sourceval delay : Ev.event_base -> float -> ('a -> unit) -> 'a -> unit

Sourceval poll : Ev.event_base -> unit

Install

Dune Dependency

Authors

Maintainers

Sources

doc/devkit.core/Devkit_core/Async/index.html

Module `Devkit_core.Async`Source

package devkit

Install

Dune Dependency

Authors

Maintainers

Sources

doc/devkit.core/Devkit_core/Async/index.html

Module Devkit_core.AsyncSource

Module `Devkit_core.Async`Source