Method poll_tcp_data

perro_source/api_modules/perro_networking/src/world.rs:312–348

(
        &mut self,
        max_per_socket: usize,
        max_bytes: usize,
        events: &mut Vec<NetworkEvent>,
    )

            }
        }
    }

    fn poll_tcp_data(
        &mut self,
        max_per_socket: usize,
        max_bytes: usize,
        events: &mut Vec<NetworkEvent>,
    ) {
        let Some(ids) = self.tcp_connections.live_ids() else {
            return;
        };
        for &i in ids.iter() {
            let Some(connection) = self.tcp_connections.get_mut(i) else {
                continue;
            };
            let id = TcpConnectionId(i);
            for _ in 0..max_per_socket {
                match connection.poll_event(max_bytes) {
                    Ok(Some(event)) => {
                        let disconnected = matches!(event, NetEvent::TcpDisconnected { .. });
                        events.push(NetworkEvent {
                            source: NetSource::TcpConnection(id),
                            event,
                        });
                        if disconnected {
                            remove_slot(&mut self.tcp_connections, i);
                            break;
                        }
                    }
                    Ok(None) => break,
                    Err(err) => {
                        events.push(net_error_event(
                            NetSource::TcpConnection(id),
                            "tcp_recv",
                            err,
                        ));
                        break;
                    }
                }
            }