arete-sdk 0.1.6

The Project Arete SDK for smart buildings
Documentation 
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

mod cache;
mod client;
mod consumer;
mod context;
mod error;
mod node;
mod provider;
mod stats;
mod system;

pub use cache::Cache;
pub use client::{Client, DEFAULT_TIMEOUT_SECS};
pub use consumer::Consumer;
pub use context::Context;
pub use error::Error;
pub use node::Node;
pub use provider::Provider;
pub use stats::Stats;
use std::sync::{Arc, Mutex};
pub use system::System;
use tungstenite::{handshake::client::Response, stream::MaybeTlsStream};

pub fn connect(url: &str) -> Result<(Client, Response), Error> {
    // Connect
    let (mut socket, res) = tungstenite::connect(url)?;

    // Configure non-blocking reads
    match socket.get_mut() {
        MaybeTlsStream::Plain(stream) => stream.set_nonblocking(true)?,
        MaybeTlsStream::Rustls(stream) => stream.get_mut().set_nonblocking(true)?,
        _ => {}
    }

    // Respond
    let client = Client::new(Arc::new(Mutex::new(socket)));
    Ok((client, res))
}