Crate rumtk_core

Source

Modules§

cache
core
log
maths
net
queue
search
strings
threading

Macros§

rumtk_async_sleep
Sleep for some duration of time in an async context. Meaning, we can be awaited.
rumtk_cache_fetch
rumtk_connect
This macro is a convenience macro that allows you to establish a connection to an endpoint. It creates and instance of [tcp::RUMClientHandle].
rumtk_create_server
Macro for creating a server instance.
rumtk_create_task
This macro creates an async body that calls the async closure and awaits it.
rumtk_create_task_args
Creates an instance of SafeTaskArgs with the arguments passed.
rumtk_exec_task
Convenience macro for packaging the task components and launching the task in one line.
rumtk_init_threads
First, let’s make sure we have tokio initialized at least once. The runtime created here will be saved to the global context so the next call to this macro will simply grab a reference to the previously initialized runtime.
rumtk_new_task_queue
rumtk_resolve_task
This macro awaits a future.
rumtk_sleep
Sleep a duration of time in a sync context, so no await can be call on the result.
rumtk_spawn_task
Puts task onto the runtime queue.
rumtk_start_server
Macro for starting the server. When a server is created, it does not start accepting clients right away. You need to call this macro to do that or call [tcp::RUMServerHandle::start] directly.
rumtk_wait_on_task
Using the initialized runtime, wait for the future to resolve in a thread blocking manner!