package devkit

  1. Overview
  2. Docs
Development kit - general purpose library

Install 

dune-project
 Dependency

github.com Readme Edit opam file Versions (8)

Authors

  1. A
    Ahrefs <github@ahrefs.com>

Maintainers

  1. I
    igor@ahrefs.com

Sources

devkit-1.20210120.tbz
md5=47338eaae436aba40abd4d194ee40054
sha256=499b050b73643f6ad7349a41485539d4166d149a07fba59cb6841f508c0297f8
sha512=6a5bf77061d390ddb331ed3d5891a5c56502be91f0eff6846202f658ebfa97ef57695d7a192cbdad4c7b8835f5665df3ea4375daf46930334ebbd9a07f00feca

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

Module Devkit_core.AsyncSource

Asynchronous IO helpers

module Ev = Libevent
Sourcemodule Internal : sig ... end
Sourceval 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.

Sourceval 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 =
  1. | End
  2. | Data of int
  3. | Block
  4. | Exn of exn
Sourceval read_some : Unix.file_descr -> bytes -> int -> int -> result
Sourceval write_some : Unix.file_descr -> string -> int -> int -> int
Sourceval 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

Sourceval show_error : [< `Eof | `EofImm | `Exn of exn | `ExnImm of exn | `Timeout ] -> string
Sourceval 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).

Sourceval 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
Sourceval 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.

Sourceval periodic_timer_now : Ev.event_base -> ?stop:bool ref -> float -> ?name:string -> (unit -> unit) -> Ev.event
Sourceval periodic_timer_wait : Ev.event_base -> ?stop:bool ref -> float -> ?name:string -> (unit -> unit) -> Ev.event
Sourceval setup_periodic_timer_now : Ev.event_base -> ?stop:bool ref -> float -> ?name:string -> (unit -> unit) -> unit
Sourceval 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