moshpit 0.1.0

A Rust implementation of in the same vein as Mosh, the mobile shell.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

// Copyright (c) 2025 moshpit developers
//
// Licensed under the Apache License, Version 2.0
// <LICENSE-APACHE or https://www.apache.org/licenses/LICENSE-2.0> or the MIT
// license <LICENSE-MIT or https://opensource.org/licenses/MIT>, at your
// option. All files in the project carrying such notice may not be copied,
// modified, or distributed except according to those terms.

use anyhow::Result;
use bon::Builder;
use libmoshpit::{ConnectionWriter, Frame};
use tokio::sync::mpsc::UnboundedReceiver;

#[derive(Builder)]
pub(crate) struct FrameSender {
    writer: ConnectionWriter,
    rx: UnboundedReceiver<Frame>,
}

impl FrameSender {
    pub(crate) async fn handle_tx(&mut self) -> Result<()> {
        while let Some(frame) = self.rx.recv().await {
            self.writer.write_frame(&frame).await?;
        }
        Ok(())
    }
}