X-Git-Url: https://code.octet-stream.net/m17rt/blobdiff_plain/b8702d115ebc071a9ae97e9aa9c4bc00196b5e26..2813fcb83452c7fd91d799a984613a616180a067:/m17app/src/app.rs diff --git a/m17app/src/app.rs b/m17app/src/app.rs index 8130455..aa040de 100644 --- a/m17app/src/app.rs +++ b/m17app/src/app.rs @@ -60,14 +60,6 @@ impl M17App { } } - pub fn transmit_packet(&self, packet_type: PacketType, payload: &[u8]) { - // hang on where do we get the LSF details from? We need a destination obviously - // our source address needs to be configured here too - // also there is possible CAN, encryption, meta payload - - // we will immediately convert this into a KISS payload before sending into channel so we only need borrow on data - } - /// Create a handle that can be used to transmit data on the TNC pub fn tx(&self) -> TxHandle { TxHandle { @@ -89,6 +81,14 @@ pub struct TxHandle { } impl TxHandle { + pub fn transmit_packet(&self, packet_type: PacketType, payload: &[u8]) { + // hang on where do we get the LSF details from? We need a destination obviously + // our source address needs to be configured here too + // also there is possible CAN, encryption, meta payload + + // we will immediately convert this into a KISS payload before sending into channel so we only need borrow on data + } + // add more methods here for stream outgoing pub fn transmit_stream_start(&self /* lsf?, payload? what needs to be configured ?! */) {} @@ -125,7 +125,7 @@ enum TncControlEvent { Close, } -fn spawn_reader(mut tnc: T, adapters: Arc>) { +fn spawn_reader(mut tnc: T, adapters: Arc>) { std::thread::spawn(move || { let mut kiss_buffer = KissBuffer::new(); let mut stream_running = false; @@ -241,7 +241,7 @@ fn spawn_reader(mut tnc: T, adapters: Arc(mut tnc: T, event_rx: mpsc::Receiver) { +fn spawn_writer(mut tnc: T, event_rx: mpsc::Receiver) { std::thread::spawn(move || { while let Ok(ev) = event_rx.recv() { match ev {