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 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67
use crate::frame::Frame; use crate::payload::SetupPayload; use crate::spi::{ClientResponder, RSocket, ServerResponder}; use crate::{Error, Result}; use async_trait::async_trait; use futures::channel::{mpsc, oneshot}; use futures::sink::Sink; use futures::stream::Stream; use std::future::Future; use std::marker::Unpin; use std::pin::Pin; use std::sync::Arc; use tokio::sync::Notify; #[derive(Clone)] pub(crate) enum Acceptor { Simple(Arc<ClientResponder>), Generate(Arc<ServerResponder>), } #[async_trait] pub trait Reader { async fn read(&mut self) -> Option<Result<Frame>>; } #[async_trait] pub trait Writer { async fn write(&mut self, frame: Frame) -> Result<()>; } pub trait Connection { fn split( self, ) -> ( Box<dyn Writer + Send + Unpin>, Box<dyn Reader + Send + Unpin>, ); } #[async_trait] pub trait Transport { type Conn: Connection + Send; async fn connect(self) -> Result<Self::Conn>; } #[async_trait] pub trait ServerTransportOld { type Item; async fn start( self, starter: Option<Box<dyn FnMut() + Send + Sync>>, acceptor: Box<dyn Fn(Self::Item) -> Result<()> + Send + Sync>, ) -> Result<()> where Self::Item: Transport + Sized; } #[async_trait] pub trait ServerTransport { type Item: Transport; async fn start(&mut self) -> Result<()>; async fn next(&mut self) -> Option<Result<Self::Item>>; }