gcast 0.1.5

A library for using Google Cast devices
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use Error;
use discovery;
use back::{net, protocol};

use mio;

/// A connection to a Cast device.
pub struct Connection
{
    pub transport: net::Transport,
}

impl Connection
{
    pub fn connect_to(device: &discovery::DeviceInfo,
                      io: &mut net::Io) -> Result<Self, Error> {
        Ok(Connection {
            transport: net::Transport::connect_to(device, io)?,
        })
    }

    /// Sends a packet through the connection.
    pub fn send(&mut self, message: &protocol::Message) -> Result<(), Error> {
        let bytes = message.as_raw_bytes()?;
        self.transport.send(bytes)?;
        Ok(())
    }

    /// Consumes all packets that have been received.
    pub fn receive(&mut self) -> Result<::std::vec::IntoIter<protocol::Message>, Error> {
        let result: Result<Vec<protocol::Message>, Error> = self.transport.receive().map(|raw_packet| {
            let message = protocol::Message::from_raw_bytes(&raw_packet)?;
            Ok(message)
        }).collect();

        Ok(result?.into_iter())
    }

    /// Handles an IO event.
    pub fn handle_event(&mut self, event: mio::Event) -> Result<(), Error> {
        self.transport.handle_event(event)
    }
}