Struct InstantServer 

pub struct InstantServer { /* private fields */ }

Implementations

impl InstantServer

pub fn new() -> Self

Examples found in repository

examples/protocol_greetings_with_instant_server.rs (line 41)

async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync + 'static>> {
    let ir = InstantRegistry::new();
    // The instant server will automatically use the instant registry when there is one.
    let is0 = InstantServer::new();
    let is1 = InstantServer::new();
    let cl0 = is0.get_colink().switch_to_generated_user().await?;
    let cl1 = is1.get_colink().switch_to_generated_user().await?;
    colink::protocol_attach!(
        cl0,
        ("greetings:initiator", Initiator),
        ("greetings:receiver", Receiver)
    );
    colink::protocol_attach!(
        cl1,
        ("greetings:initiator", Initiator),
        ("greetings:receiver", Receiver)
    );
    let participants = vec![
        Participant {
            user_id: cl0.get_user_id()?,
            role: "initiator".to_string(),
        },
        Participant {
            user_id: cl1.get_user_id()?,
            role: "receiver".to_string(),
        },
    ];
    let task_id = cl0
        .run_task("greetings", "test".as_bytes(), &participants, true)
        .await?;
    let res = cl1
        .read_or_wait(&format!("tasks:{}:output", task_id))
        .await?;
    println!("{}", String::from_utf8_lossy(&res));
    Ok(())
}

pub fn new_with_config(user_init_config: &str) -> Self

pub fn get_colink(&self) -> CoLink

Examples found in repository

examples/protocol_greetings_with_instant_server.rs (line 43)

async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync + 'static>> {
    let ir = InstantRegistry::new();
    // The instant server will automatically use the instant registry when there is one.
    let is0 = InstantServer::new();
    let is1 = InstantServer::new();
    let cl0 = is0.get_colink().switch_to_generated_user().await?;
    let cl1 = is1.get_colink().switch_to_generated_user().await?;
    colink::protocol_attach!(
        cl0,
        ("greetings:initiator", Initiator),
        ("greetings:receiver", Receiver)
    );
    colink::protocol_attach!(
        cl1,
        ("greetings:initiator", Initiator),
        ("greetings:receiver", Receiver)
    );
    let participants = vec![
        Participant {
            user_id: cl0.get_user_id()?,
            role: "initiator".to_string(),
        },
        Participant {
            user_id: cl1.get_user_id()?,
            role: "receiver".to_string(),
        },
    ];
    let task_id = cl0
        .run_task("greetings", "test".as_bytes(), &participants, true)
        .await?;
    let res = cl1
        .read_or_wait(&format!("tasks:{}:output", task_id))
        .await?;
    println!("{}", String::from_utf8_lossy(&res));
    Ok(())
}

Trait Implementations

impl Default for InstantServer

fn default() -> Self

Returns the “default value” for a type.

impl Drop for InstantServer

fn drop(&mut self)

Executes the destructor for this type.