server/src/channels/server_command.rs

use std::future::Future;

use crate::configs::server::ServerConfig;
use crate::streaming::systems::system::SharedSystem;
use flume::{Receiver, Sender};

pub trait ServerCommand<C> {
    fn execute(&mut self, system: &SharedSystem, command: C) -> impl Future<Output = ()>;

    fn start_command_sender(
        &mut self,
        system: SharedSystem,
        config: &ServerConfig,
        sender: Sender<C>,
    );

    fn start_command_consumer(
        self,
        system: SharedSystem,
        config: &ServerConfig,
        receiver: Receiver<C>,
    );
}