Lines Matching refs:S
643 pub struct SingleDispatcher<S: Service> {
644 service: S,
648 impl<S: Service> SingleDispatcher<S> {
649 fn new(service: S, port: PortCfg) -> Self { in new() argument
654 impl<S: Service> Dispatcher for SingleDispatcher<S> {
655 type Connection = S::Connection;
674 let msg = S::Message::deserialize(&buffer[..byte_count], &mut handles[..handle_count]) in on_message()
687 S::Message::MAX_SERIALIZED_SIZE in max_message_length()
696 pub struct SingleUnbufferedDispatcher<S: UnbufferedService> {
697 service: S,
701 impl<S: UnbufferedService> SingleUnbufferedDispatcher<S> {
702 fn new(service: S, port: PortCfg) -> Self { in new() argument
707 impl<S: UnbufferedService> Dispatcher for SingleUnbufferedDispatcher<S> {
708 type Connection = S::Connection;
916 S: Service,
920 > Manager<SingleDispatcher<S>, B, PORT_COUNT, MAX_CONNECTION_COUNT>
963 pub fn new(service: S, port_cfg: PortCfg, buffer: B) -> Result<Self> { in new() argument
969 impl<S: UnbufferedService, const PORT_COUNT: usize, const MAX_CONNECTION_COUNT: usize>
970 Manager<SingleUnbufferedDispatcher<S>, [u8; 0], PORT_COUNT, MAX_CONNECTION_COUNT>
976 pub fn new_unbuffered(service: S, port_cfg: PortCfg) -> Result<Self> { in new_unbuffered() argument
1363 fn serialize<'a: 's, S: Serializer<'s>>( in serialize()
1365 serializer: &mut S, in serialize() argument
1366 ) -> core::result::Result<S::Ok, S::Error> { in serialize()