Struct ThrottleableRuntime

pub struct ThrottleableRuntime {
    name: String,
    handle: Handle,
    shared_with_future: Arc<RuntimeRateLimiter>,
    _dropper: Arc<Dropper>,
}

A runtime to run future tasks

Fields

name: String

handle: Handle

shared_with_future: Arc<RuntimeRateLimiter>

_dropper: Arc<Dropper>

Implementations

impl ThrottleableRuntime

pub(crate) fn new( name: &str, priority: Priority, handle: Handle, dropper: Arc<Dropper>, ) -> Result<Self>

Trait Implementations

impl BuilderBuild<ThrottleableRuntime> for Builder

fn build(&mut self) -> Result<ThrottleableRuntime>

impl Clone for ThrottleableRuntime

fn clone(&self) -> ThrottleableRuntime

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ThrottleableRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RuntimeTrait for ThrottleableRuntime

fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawn a future and execute it in this thread pool

Similar to tokio::runtime::Runtime::spawn()

fn spawn_blocking<F, R>(&self, func: F) -> JoinHandle<R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

Run the provided function on an executor dedicated to blocking operations.

fn block_on<F: Future>(&self, future: F) -> F::Output

Run a future to complete, this is the runtime’s entry point

fn builder() -> Builder

Get a runtime builder

fn name(&self) -> &str

Get the name of the runtime