[−][src]Struct showdown::Receiver

pub struct Receiver { /* fields omitted */ }

Message receiver.

Examples

#![feature(async_await, await_macro, futures_api)]
#![recursion_limit = "128"]

use futures03::prelude::*;
use showdown::message::{Kind, ParsedMessage, UpdateUser};
use showdown::{connect, Result, RoomId};
use tokio::await;
use tokio::runtime::Runtime;

async fn start() -> Result<()> {
    let (_, mut receiver) = await!(connect("showdown"))?;
    let message = await!(receiver.receive())?;
    match message.parse() {
        ParsedMessage {
            room_id: RoomId(""),
            kind:
                Kind::UpdateUser(UpdateUser {
                    username,
                    named: false,
                    ..
                }),
        } => {
            assert!(username.starts_with("Guest "));
        }
        _ => panic!(),
    }
    Ok(())
}

Runtime::new()
    .unwrap()
    .block_on_all(start().boxed().compat())
    .unwrap();

Methods

impl Receiver
[src]

pub fn receive(
    &mut self
) -> impl Future<Item = Message, Error = Error> + '_
[src]

Trait Implementations

impl Debug for Receiver
[src]

Auto Trait Implementations

impl Send for Receiver

impl Sync for Receiver

Blanket Implementations

impl<T> From for T
[src]

impl<T, U> Into for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom for T where
    T: From<U>, 
[src]

type Error = !

🔬 This is a nightly-only experimental API. (try_from)

The type returned in the event of a conversion error.

impl<T> Borrow for T where
    T: ?Sized, 
[src]

impl<T, U> TryInto for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

🔬 This is a nightly-only experimental API. (try_from)

The type returned in the event of a conversion error.

impl<T> BorrowMut for T where
    T: ?Sized, 
[src]

impl<T> Any for T where
    T: 'static + ?Sized, 
[src]

impl<T> Erased for T

impl<T> Typeable for T where
    T: Any, 

fn get_type(&self) -> TypeId

Get the TypeId of this object.