Struct futuresdr::runtime::Runtime

pub struct Runtime<'a, S> { /* private fields */ }

This is the Runtime that runs a Flowgraph to completion.

Runtimes are generic over the scheduler used to run the Flowgraph.

Implementations

impl<'a> Runtime<'a, SmolScheduler>

pub fn new() -> Self

Constructs a new Runtime using SmolScheduler::default() for the Scheduler.

pub fn with_custom_routes(routes: Router) -> Self

impl<'a, S: Scheduler> Runtime<'a, S>

pub fn with_scheduler(scheduler: S) -> Self

Create a Runtime with a given Scheduler

pub fn with_config(scheduler: S, routes: Router) -> Self

pub fn spawn<T: Send + 'static>(
&self,
future: impl Future<Output = T> + Send + 'static
) -> Task<T>

pub fn block_on<T: Send + 'static>(
&self,
future: impl Future<Output = T> + Send + 'static
) -> T

pub fn spawn_background<T: Send + 'static>(
&self,
future: impl Future<Output = T> + Send + 'static
)

pub fn spawn_blocking<T: Send + 'static>(
&self,
future: impl Future<Output = T> + Send + 'static
) -> Task<T>

pub fn spawn_blocking_background<T: Send + 'static>(
&self,
future: impl Future<Output = T> + Send + 'static
)

pub async fn start<'b>(
&'a self,
fg: Flowgraph
) -> (TaskHandle<'b, Result<Flowgraph>>, FlowgraphHandle)where
'a: 'b,

pub fn run(&self, fg: Flowgraph) -> Result<Flowgraph>

Main method that kicks-off the running of a Flowgraph.

pub async fn run_async(&self, fg: Flowgraph) -> Result<Flowgraph>

pub fn scheduler(&self) -> S

Trait Implementations

impl<'a> Default for Runtime<'a, SmolScheduler>

fn default() -> Self

Returns the “default value” for a type.