Struct SocketReader 

pub(crate) struct SocketReader {
    socket: Box<dyn ReadHalf>,
    senders: Arc<Mutex<HashMap<Option<OwnedMatchRule>, Sender<Result<Message>>>>>,
    already_received_bytes: Vec<u8>,
    already_received_fds: Vec<OwnedFd>,
    prev_seq: u64,
    activity_event: Arc<Event>,
}

Fields

socket: Box<dyn ReadHalf>

senders: Arc<Mutex<HashMap<Option<OwnedMatchRule>, Sender<Result<Message>>>>>

already_received_bytes: Vec<u8>

already_received_fds: Vec<OwnedFd>

prev_seq: u64

activity_event: Arc<Event>

Implementations

impl SocketReader

pub fn new( socket: Box<dyn ReadHalf>, senders: Arc<Mutex<HashMap<Option<OwnedMatchRule>, Sender<Result<Message>>>>>, already_received_bytes: Vec<u8>, already_received_fds: Vec<OwnedFd>, activity_event: Arc<Event>, ) -> Self

pub fn spawn(self, executor: &Executor<'_>) -> Task<()>

async fn receive_msg(self)

async fn read_socket(&mut self) -> Result<Message>

Trait Implementations

impl Debug for SocketReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.