mcfunction-debugger 2.0.0

// Mcfunction-Debugger is a debugger for Minecraft's *.mcfunction files that does not require any
// Minecraft mods.
//
// © Copyright (C) 2021-2024 Adrodoc <adrodoc55@googlemail.com> & Skagaros <skagaros@gmail.com>
//
// This file is part of Mcfunction-Debugger.
//
// Mcfunction-Debugger is free software: you can redistribute it and/or modify it under the terms of
// the GNU General Public License as published by the Free Software Foundation, either version 3 of
// the License, or (at your option) any later version.
//
// Mcfunction-Debugger is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
// without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along with Mcfunction-Debugger.
// If not, see <http://www.gnu.org/licenses/>.

use crate::dap::MessageWriter;
use debug_adapter_protocol::{ProtocolMessage, ProtocolMessageContent};
use futures::Sink;
use log::trace;
use tokio::sync::mpsc::UnboundedReceiver;

pub(super) struct DebugAdapterSender<O>
where
    O: Sink<ProtocolMessage>,
{
    pub message_writer: MessageWriter<O>,
    pub outbox_receiver: UnboundedReceiver<ProtocolMessageContent>,
}

impl<O> DebugAdapterSender<O>
where
    O: Sink<ProtocolMessage> + Unpin,
{
    pub async fn run(mut self) -> Result<(), O::Error> {
        trace!("Starting sender");
        while let Some(message) = self.outbox_receiver.recv().await {
            self.message_writer.write_msg(message).await?;
        }
        trace!("Stopped sender");
        Ok(())
    }
}