Skip to main content

Module rt

Module rt 

Source
Expand description

Runtime APIs for running tasks on the current thread.

Modules§

channel
A one-shot, futures-aware channel.
connect
DNS-aware TCP connector service.
polling
rt_default
rt_tokio
signals
tokio
uring

Macros§

syscall
Helper macro to execute a system call

Structs§

Arbiter
An asynchronous execution environment running on one OS thread.
BlockingError
Error returned when blocking work cannot produce a result.
BlockingResult
Future resolving to the result of blocking work.
Builder
Builder for an ntex runtime system.
DefaultRuntime
The default runtime.
Handle
Handle to the runtime.
Id
Identifier assigned to a running System.
JoinError
JoinHandle
PingRecord
Runtime
The async runtime for ntex.
RuntimeBuilder
Builder for Runtime.
System
Runtime manager for a group of arbiter threads.
SystemRunner
A configured system that has not yet started its event loop.
ThreadPool
A thread pool for executing blocking operations.

Enums§

DriverType
PollResult

Traits§

Driver
Notify
Reactor
Runtime reactor used for network connection and transport operations.
Runner

Functions§

from_tcp_stream
Converts a standard-library TCP stream into an Io value.
from_unix_stream
Converts a standard-library Unix stream into an Io value.
get_item
Returns a cloned value from the current arbiter’s thread-local storage.
set_item
Inserts a value into the current arbiter’s thread-local storage.
spawn
Spawn a future on the current thread.
spawn_blocking
Submits blocking work and returns a future for its result.
task_callbacks⚠
Safety
task_opt_callbacks⚠
Safety
tcp_connect
Opens a TCP connection to a remote host.
unix_connect
Opens a Unix domain socket connection.
with_item
Provides access to a value in the current arbiter’s thread-local storage.
with_reactor
Sets the current reactor and runs the provided closure.

Type Aliases§

BlockFuture