Struct PriorityMuxer 

pub struct PriorityMuxer {
    global: Global,
    inputs: BTreeMap<i32, InputEntry>,
    input_id: usize,
    timeouts: HashMap<usize, Box<dyn Fn() -> Pin<Box<dyn Future<Output = (usize, i32)> + Send + Sync>> + Send + Sync>>,
    effect_runner: EffectRunner,
}

Fields

global: Global

inputs: BTreeMap<i32, InputEntry>

input_id: usize

timeouts: HashMap<usize, Box<dyn Fn() -> Pin<Box<dyn Future<Output = (usize, i32)> + Send + Sync>> + Send + Sync>>

effect_runner: EffectRunner

Implementations

impl PriorityMuxer

pub async fn new(global: Global, config: MuxerConfig) -> Self

fn current_priority(&self) -> i32

fn notify_output_change(&mut self) -> Option<MuxedMessage>

fn insert_input( &mut self, priority: i32, input: InputMessage, effect_key: Option<RunningEffectKey>, ) -> Option<InputEntry>

fn clear_inputs(&mut self)

fn clear_input(&mut self, priority: i32) -> bool

async fn clear_all(&mut self) -> Option<MuxedMessage>

async fn clear(&mut self, priority: i32) -> Option<MuxedMessage>

async fn handle_input(&mut self, input: InputMessage) -> Option<MuxedMessage>

async fn handle_timeout(&mut self, __arg1: (usize, i32)) -> Option<MuxedMessage>

pub async fn handle_message( &mut self, input: InputMessage, ) -> Option<MuxedMessage>

pub async fn current_priorities(&self) -> Vec<PriorityInfo>

async fn handle_effect_message( &mut self, msg: Option<EffectRunnerUpdate>, ) -> Option<MuxedMessage>

pub async fn update(&mut self) -> Option<MuxedMessage>