Struct Send 

pub struct Send { /* private fields */ }

Implementations

impl Send

pub fn new( mode: SendMode, from: SocketAddr, to: SocketAddr, buffer: Vec<u8>, ) -> Self

Creates a new Send action.

Examples found in repository

examples/bind_and_connect.rs (lines 57-62)

fn create_node_1() -> Node {
    let mut node = Node::new("test-node-1");
    let bind_action = Bind::new("192.168.1.10:3000".parse().unwrap());
    let sleep_action = Sleep::new(1000);
    let connection_action = Connect::new(
        "192.168.1.10:0".parse().unwrap(),
        "192.168.1.11:4000".parse().unwrap(),
        1000,
    );
    let send_unicast_action = Send::new(
        SendMode::Unicast,
        "192.168.1.10:3000".parse().unwrap(),
        "192.168.1.11:4000".parse().unwrap(),
        vec![1, 2, 3, 4],
    );

    let send_broadcast_action = Send::new(
        SendMode::Broadcast,
        "192.168.1.10:0".parse().unwrap(),
        "192.168.1.255:49999".parse().unwrap(),
        vec![1, 2, 3, 4],
    );

    let wait_connection_action = Wait::new(WaitEvent::Connection(ConnectPredicate::new(
        "192.168.1.11:0".parse().unwrap(),
        "192.168.1.10:3000".parse().unwrap(),
    )));

    let wait_message_action = Wait::new(WaitEvent::Messages(ReceivePredicate::new(vec![
        MessagesPredicate {
            from: "192.168.1.11:0".parse().unwrap(),
            to: "192.168.1.10:3000".parse().unwrap(),
            buffer: vec![1, 1],
        },
    ])));

    node.add_action(bind_action);
    node.add_action(sleep_action.clone());
    node.add_action(send_broadcast_action);
    node.add_action(wait_connection_action);
    node.add_action(wait_message_action);
    node.add_action(connection_action);
    node.add_action(send_unicast_action);
    node.add_action(sleep_action);

    node
}

fn create_node_2() -> Node {
    let mut node = Node::new("test-node-2");
    let bind_action = Bind::new("192.168.1.11:4000".parse().unwrap());
    let sleep_action = Sleep::new(5000);
    let connection_action = Connect::new(
        "192.168.1.11:0".parse().unwrap(),
        "192.168.1.10:3000".parse().unwrap(),
        1000,
    );

    let send_unicast_action = Send::new(
        SendMode::Unicast,
        "192.168.1.11:4000".parse().unwrap(),
        "192.168.1.10:3000".parse().unwrap(),
        vec![1, 1],
    );

    node.add_action(bind_action);
    node.add_action(sleep_action.clone());
    node.add_action(connection_action);
    node.add_action(sleep_action);
    node.add_action(send_unicast_action);

    node
}

pub fn from(&self) -> &SocketAddr

pub fn to(&self) -> &SocketAddr

pub fn buffer(&self) -> &[u8]

Trait Implementations

impl Action for Send

fn perform<'life0, 'async_trait>( &'life0 self, ctx: Arc<Mutex<NodeContext>>, ) -> Pin<Box<dyn Future<Output = Result<(), ActionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends data from from to to using the specified mode.

fn name(&self) -> String

impl Clone for Send

fn clone(&self) -> Send

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Send

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

Formats the value using the given formatter.

impl PartialEq for Send

fn eq(&self, other: &Send) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Send