Struct cord_client::Conn

pub struct Conn { /* fields omitted */ }

A Conn is used to connect to and communicate with a broker.

Examples

use cord_client::Conn;
use futures::{future, Future};
use tokio;

let fut = Conn::new("127.0.0.1:7101".parse().unwrap()).and_then(|mut conn| {
    // Tell the broker we're going to provide the namespace /users
    conn.provide("/users".into()).unwrap();

    // Start publishing events...
    conn.event("/users/mark".into(), "Mark has joined").unwrap();

    Ok(())
}).map_err(|_| ());

tokio::run(fut);

Methods

impl Conn

pub fn new(addr: SocketAddr) -> impl Future<Item = Conn, Error = Error>

Connect to a broker

pub fn forward<S>(self, stream: S) -> impl Future<Item = Self, Error = Error> where
    S: Stream<Item = Message, Error = Error>, 

If you have a stream that produces Messages, you can forward that directly to the inner Sink instead of calling the helper methods.

pub fn provide(&mut self, namespace: Pattern) -> Result<()>

Inform the broker that you will be providing a new namespace

pub fn revoke(&mut self, namespace: Pattern) -> Result<()>

Inform the broker that you will no longer be providing a namespace

pub fn subscribe(&mut self, namespace: Pattern) -> Result<Subscriber>

Subscribe to another provider's namespace

Examples

conn.subscribe("/users/".into()).unwrap().for_each(|msg| {
    // Handle the message...
    dbg!("The following user just joined: {}", msg);

    Ok(())
})

pub fn unsubscribe(&mut self, namespace: Pattern) -> Result<()>

Unsubscribe from another provider's namespace

pub fn event<S: Into<String>>(
    &mut self,
    namespace: Pattern,
    data: S
) -> Result<()>

Publish an event to your subscribers

Trait Implementations

impl Clone for Conn

fn clone(&self) -> Conn

Returns a copy of the value.

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

Performs copy-assignment from source.