mod connection;
pub mod deli_note;
mod events;
pub mod proto;
pub use connection::Connection;
pub use events::{BroadcastEvents, CollabEvents};
use super::*;
use futures_util::stream::SplitSink;
use tokio::{
net::TcpStream,
sync::mpsc::{UnboundedReceiver, UnboundedSender},
};
use tokio_tungstenite::{tungstenite::Message, WebSocketStream};