Struct WorkerManager

pub struct WorkerManager { /* private fields */ }

Container that creates Worker instances.

Examples

use futures_lite::future;
use mediasoup::worker::WorkerSettings;
use mediasoup::worker_manager::WorkerManager;

// Create a manager that will use specified binary for spawning new worker thread
let worker_manager = WorkerManager::new();

future::block_on(async move {
    // Create a new worker with default settings
    let worker = worker_manager
        .create_worker(WorkerSettings::default())
        .await
        .unwrap();
})

If you already happen to have async_executor::Executor instance available or need a multi-threaded executor, WorkerManager::with_executor() can be used to create an instance instead.

Implementations

impl WorkerManager

pub fn new() -> Self

Create new worker manager, internally a new single-threaded executor will be created.

pub fn with_executor(executor: Arc<Executor<'static>>) -> Self

Create new worker manager, uses externally provided executor.

pub async fn create_worker( &self, worker_settings: WorkerSettings, ) -> Result<Worker>

Creates a new worker with the given settings.

Worker manager will be kept alive as long as at least one worker instance is alive.

pub fn on_new_worker<F: Fn(&Worker) + Send + Sync + 'static>( &self, callback: F, ) -> HandlerId

Callback is called when a new worker is created.

Trait Implementations

impl Clone for WorkerManager

fn clone(&self) -> WorkerManager

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerManager

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

Formats the value using the given formatter.

impl Default for WorkerManager

fn default() -> Self

Returns the “default value” for a type.