From 2211f324782cdc617b4b5ecd071178e372539fe4 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Wed, 26 Mar 2025 14:29:40 +0000 Subject: refactor: rename crates and move client logic to separate crate `filament` --- jabber/src/jabber_stream/bound_stream.rs | 87 -------------------------------- 1 file changed, 87 deletions(-) delete mode 100644 jabber/src/jabber_stream/bound_stream.rs (limited to 'jabber/src/jabber_stream') diff --git a/jabber/src/jabber_stream/bound_stream.rs b/jabber/src/jabber_stream/bound_stream.rs deleted file mode 100644 index 25b79ff..0000000 --- a/jabber/src/jabber_stream/bound_stream.rs +++ /dev/null @@ -1,87 +0,0 @@ -use std::ops::{Deref, DerefMut}; - -use tokio::io::{AsyncRead, AsyncWrite}; - -use super::{JabberReader, JabberStream, JabberWriter}; - -pub struct BoundJabberStream(JabberStream); - -impl Deref for BoundJabberStream -where - S: AsyncWrite + AsyncRead + Unpin + Send, -{ - type Target = JabberStream; - - fn deref(&self) -> &Self::Target { - &self.0 - } -} - -impl DerefMut for BoundJabberStream -where - S: AsyncWrite + AsyncRead + Unpin + Send, -{ - fn deref_mut(&mut self) -> &mut Self::Target { - &mut self.0 - } -} - -impl BoundJabberStream { - pub fn split(self) -> (BoundJabberReader, BoundJabberWriter) { - let (reader, writer) = self.0.split(); - (BoundJabberReader(reader), BoundJabberWriter(writer)) - } -} - -pub struct BoundJabberReader(JabberReader); - -impl BoundJabberReader { - pub fn unsplit(self, writer: BoundJabberWriter) -> BoundJabberStream { - BoundJabberStream(self.0.unsplit(writer.0)) - } -} - -impl std::ops::Deref for BoundJabberReader { - type Target = JabberReader; - - fn deref(&self) -> &Self::Target { - &self.0 - } -} - -impl std::ops::DerefMut for BoundJabberReader { - fn deref_mut(&mut self) -> &mut Self::Target { - &mut self.0 - } -} - -pub struct BoundJabberWriter(JabberWriter); - -impl BoundJabberWriter { - pub fn unsplit(self, reader: BoundJabberReader) -> BoundJabberStream { - BoundJabberStream(self.0.unsplit(reader.0)) - } -} - -impl std::ops::Deref for BoundJabberWriter { - type Target = JabberWriter; - - fn deref(&self) -> &Self::Target { - &self.0 - } -} - -impl std::ops::DerefMut for BoundJabberWriter { - fn deref_mut(&mut self) -> &mut Self::Target { - &mut self.0 - } -} - -impl JabberStream -where - S: AsyncWrite + AsyncRead + Unpin + Send, -{ - pub fn to_bound_jabber(self) -> BoundJabberStream { - BoundJabberStream(self) - } -} -- cgit