Lines Matching refs:UnbufferedService

408 pub trait UnbufferedService {  interface
450 impl<T, U: Deserialize, V: Service<Connection = T, Message = U>> UnbufferedService for V {
458     ) -> Result<ConnectResult<<Self as UnbufferedService>::Connection>> {  in on_connect()
464         connection: &<Self as UnbufferedService>::Connection,  in on_message()
481     fn on_disconnect(&self, connection: &<Self as UnbufferedService>::Connection) {  in on_disconnect()
522     ($vis:vis $wrapper:ident ($inner:ty: UnbufferedService)) => {
568         impl $crate::UnbufferedService for $wrapper {
569             type Connection = <$inner as $crate::UnbufferedService>::Connection;
577                 <$inner as $crate::UnbufferedService>::on_connect(&self.0, port, handle, peer)
586 …             <$inner as $crate::UnbufferedService>::on_message(&self.0, connection, handle, buffer)
590                 <$inner as $crate::UnbufferedService>::on_disconnect(&self.0, connection)
594                 <$inner as $crate::UnbufferedService>::max_message_length(&self.0)
696 pub struct SingleUnbufferedDispatcher<S: UnbufferedService> {
701 impl<S: UnbufferedService> SingleUnbufferedDispatcher<S> {
707 impl<S: UnbufferedService> Dispatcher for SingleUnbufferedDispatcher<S> {
832             $($service(<$service$(<$slt>)? as $crate::UnbufferedService>::Connection)),+
850                         $crate::UnbufferedService::on_connect(&**s, port, handle, peer)
865                             $crate::UnbufferedService::on_message(&**s, conn, handle, buffer)
877                             $crate::UnbufferedService::on_disconnect(&**s, conn)
891                             <$service as $crate::UnbufferedService>::max_message_length(&**service)
969 impl<S: UnbufferedService, const PORT_COUNT: usize, const MAX_CONNECTION_COUNT: usize>
1194         TipcError, UnbufferedService, Uuid,
1438     impl UnbufferedService for Service3 {
1462     wrap_service!(WrappedService3(Service3: UnbufferedService));