pub struct BiProxy<P>where
P: IdentifierPacket,{ /* private fields */ }
Implementations§
Source§impl<P> BiProxy<P>where
P: IdentifierPacket,
impl<P> BiProxy<P>where
P: IdentifierPacket,
pub fn new(read_buffer_size: usize) -> Self
pub async fn accept_tcpstream<PP: PacketProcessor<P> + Clone>( &self, key: &str, stream: TcpStream, processor: PP, )
pub async fn send_oneway(&self, key: &str, data: P) -> Result<()>
pub async fn send(&self, key: &str, data: P) -> Result<P>
Trait Implementations§
Auto Trait Implementations§
impl<P> Freeze for BiProxy<P>
impl<P> !RefUnwindSafe for BiProxy<P>
impl<P> Send for BiProxy<P>
impl<P> Sync for BiProxy<P>where
P: Sync,
impl<P> Unpin for BiProxy<P>where
P: Unpin,
impl<P> !UnwindSafe for BiProxy<P>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more