Lines Matching refs:ports
366 /// A service which handles IPC messages for a collection of ports.
369 /// set of ports it handles, with a [`Manager`] which then dispatches
498 /// The wrapper(s) can be used to serve multiple ports using
633 /// Get the list of ports this dispatcher handles.
645 ports: [PortCfg; 1],
650 Self { service, ports: [port] }
691 &self.ports
698 ports: [PortCfg; 1],
703 Self { service, ports: [port] }
737 &self.ports
748 /// usize parameter specifying how many ports the dispatcher will handle.
762 /// // Create a new dispatcher that handles two ports
790 /// different servers can be bound to different ports using the same event loop
793 ports: arrayvec::ArrayVec::<$crate::PortCfg, PORT_COUNT>,
800 ports: arrayvec::ArrayVec::<_, PORT_COUNT>::new(),
807 if self.ports.is_full() || self.services.is_full() {
812 self.ports.push_unchecked(port);
844 let port_idx = self.ports.iter()
884 self.ports.as_slice()
989 /// Create a manager that can handle multiple services and ports
1010 /// // Create a new dispatcher that handles two ports
1030 let ports: Vec<Rc<Channel<D>>> = dispatcher
1035 let ports: [Rc<Channel<D>>; PORT_COUNT] = ports
1038 let handle_set = HandleSet::try_new(ports)?;
1300 expect!(channel.is_ok(), "create ports");
1314 expect!(channel.is_ok(), "create ports");
1331 "max number of ports reached",
1343 expect!(channel.is_ok(), "create ports");