Struct Wait 

pub struct Wait { /* private fields */ }

Implementations

impl Wait

pub fn new(event: WaitEvent) -> Self

Examples found in repository

examples/bind_and_connect.rs (lines 71-74)

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
}

pub fn event(&self) -> &WaitEvent

Trait Implementations

impl Action for Wait

fn name(&self) -> String

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,

impl Clone for Wait

fn clone(&self) -> Wait

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Wait

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

Formats the value using the given formatter.

impl PartialEq for Wait

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Wait