Struct TraktorServer 

struct TraktorServer {
    output: UnboundedSender<ServerMessage>,
    debug_logging: bool,
    session_id: String,
    is_initialized: bool,
    queue: Vec<StateUpdate>,
    deck_files: (String, String, String, String),
    loaded_images: Vec<String>,
    pending_images: Vec<String>,
    cover_socket_id: usize,
    cover_sockets: HashMap<usize, UnboundedSender<Message>>,
}

Fields

output: UnboundedSender<ServerMessage>

debug_logging: bool

session_id: String

is_initialized: bool

queue: Vec<StateUpdate>

deck_files: (String, String, String, String)

loaded_images: Vec<String>

pending_images: Vec<String>

cover_socket_id: usize

cover_sockets: HashMap<usize, UnboundedSender<Message>>

Implementations

impl TraktorServer

pub fn new(output: UnboundedSender<ServerMessage>) -> Self

async fn send_message(&mut self, message: ServerMessage)

async fn send_messages( &mut self, messages: impl IntoIterator<Item = ServerMessage>, )

pub async fn send_ready( &mut self, app_input_sender: UnboundedSender<AppMessage>, )

pub fn reconnect(&mut self, debug_logging: bool)

fn get_required_images(&self) -> Vec<String>

async fn on_update_deck_files(&mut self)

async fn handle_connect(&mut self) -> Json

async fn handle_init( &mut self, request: InitializeRequest, ) -> impl Reply + use<>

async fn handle_update( &mut self, session_id: String, update: StateUpdate, ) -> impl Reply + use<>

async fn handle_cover(&mut self, path: String, data: Bytes) -> StatusCode

async fn handle_socket_connect(&mut self, tx: UnboundedSender<Message>) -> usize

fn handle_socket_disconnect(&mut self, id: usize)

async fn handle_log(&mut self, msg: String) -> impl Reply + use<>

impl TraktorServer

pub fn routes( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone + use<>

fn with_state( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (Arc<Mutex<Self>>,), Error = Infallible> + Clone

fn is_started( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = ((),), Error = Rejection> + Clone

fn json_body<T: DeserializeOwned + Send>() -> impl Filter<Extract = (T,), Error = Rejection> + Clone

fn route_connect( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone

fn route_init( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone

fn route_update( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone

fn route_update_sub_routes() -> impl Filter<Extract = ((String, StateUpdate),), Error = Rejection> + Clone

fn route_cover( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone

fn route_cover_upload( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone

fn route_cover_socket( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone

fn route_log( state: Arc<Mutex<Self>>, ) -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone