api

reactor.ch

Declarations in reactor.ch

1 declarationsasync

Declarations

Public only
async#
Publicnamespace
namespace async
the requested operation. Polling is non-blocking: a `Pending` poll registers
ReactorFd#
Publicstruct
struct ReactorFd { var fd : int var events : short var read_waker : Waker var write_waker : Waker var next : *ReactorFd }
delete#
function
func delete(self : *ReactorFd) : void
Reactor#
Publicstruct
struct Reactor { var m : mutex var head : *ReactorFd }
delete#
function
func delete(self : *Reactor) : void
reactor#
Publicfunction
func reactor() : *Reactor
reactor_register#
Publicfunction
func reactor_register(fd : int, events : short, waker : Waker) : void
reactor_has_fds#
Publicfunction
func reactor_has_fds() : bool
reactor_poll#
Publicfunction
func reactor_poll(timeout_ms : int) : int
Poll the registered fds once, waking any task whose fd became ready. Blocks
ReadyState#
Publicstruct
struct ReadyState { var fd : int var events : short var parked : bool var vtbl : *FutureTable<Unit> }
An awaitable readiness future for a raw fd.
ready_poll#
Publicfunction
func ready_poll(frame : *void, cx : *Context) : Poll<Unit>
ready_drop#
Publicfunction
func ready_drop(frame : *void) : void
make_ready#
function
func make_ready(fd : int, events : short) : FutureHandle<Unit>
AsyncFd#
Publicstruct
struct AsyncFd { var fd : int }
A registered file descriptor. `readable`/`writable` complete when the fd is
readable#
Publicfunction
func readable(self : &AsyncFd) : FutureHandle<Unit>
writable#
Publicfunction
func writable(self : &AsyncFd) : FutureHandle<Unit>
readable#
Publicfunction
func readable(fd : int) : FutureHandle<Unit>
writable#
Publicfunction
func writable(fd : int) : FutureHandle<Unit>
Chemical API Referencechemicallang.com  ·  GitHub