Struct P2P 

pub struct P2P(/* private fields */);

Implementations

impl P2P

pub fn raw_handle(&self) -> EOS_HP2P

Examples found in repository

examples/platform_minimal.rs (line 34)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    initialize(InitializeOptions {
        product_name: "eos-rs-example".to_string(),
        product_version: "0.1.0".to_string(),
    })?;

    let platform = Platform::create(PlatformOptions {
        product_id: required_env("EOS_PRODUCT_ID")?,
        sandbox_id: required_env("EOS_SANDBOX_ID")?,
        deployment_id: required_env("EOS_DEPLOYMENT_ID")?,
        client_id: required_env("EOS_CLIENT_ID")?,
        client_secret: required_env("EOS_CLIENT_SECRET")?,
        is_server: false,
        encryption_key: None,
        override_country_code: None,
        override_locale_code: None,
    })?;

    // In a real application, call this from your main loop.
    platform.tick();

    // Optional: access low-level handles for APIs not yet wrapped.
    let _auth = platform.auth().raw_handle();
    let _connect = platform.connect().raw_handle();
    let _lobby = platform.lobby().raw_handle();
    let _p2p = platform.p2p().raw_handle();

    drop(platform);
    shutdown()?;
    println!("eos-rs minimal flow completed.");
    Ok(())
}

pub fn query_nat_type(&self, cb: impl FnOnce(Result<NatType>) + Send + 'static)

pub fn get_nat_type(&self) -> Result<NatType>

pub fn set_relay_control(&self, relay: RelayControl) -> Result<()>

pub fn get_relay_control(&self) -> Result<RelayControl>

pub fn set_port_range(&self, port: u16, max_additional_ports: u16) -> Result<()>

pub fn get_port_range(&self) -> Result<(u16, u16)>

pub fn set_packet_queue_size( &self, incoming_max: u64, outgoing_max: u64, ) -> Result<()>

pub fn get_packet_queue_info(&self) -> Result<PacketQueueInfo>

pub fn send_packet( &self, local_user: ProductUserId, remote_user: ProductUserId, socket_name: &str, channel: u8, data: &[u8], reliability: PacketReliability, allow_delayed_delivery: bool, disable_auto_accept_connection: bool, ) -> Result<()>

pub fn get_next_received_packet_size( &self, local_user: ProductUserId, requested_channel: Option<u8>, ) -> Result<u32>

pub fn receive_packet( &self, local_user: ProductUserId, max_data_size_bytes: u32, requested_channel: Option<u8>, ) -> Result<ReceivedPacket>

pub fn accept_connection( &self, local_user: ProductUserId, remote_user: ProductUserId, socket_name: &str, ) -> Result<()>

pub fn close_connection( &self, local_user: ProductUserId, remote_user: ProductUserId, socket_name: Option<&str>, ) -> Result<()>

pub fn close_connections( &self, local_user: ProductUserId, socket_name: &str, ) -> Result<()>

pub fn clear_packet_queue( &self, local_user: ProductUserId, remote_user: ProductUserId, socket_name: &str, ) -> Result<()>