hyperstack-sdk 0.6.9

Rust SDK client for connecting to HyperStack streaming servers
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

//! Rust client SDK for connecting to HyperStack streaming servers.
//!
//! ```rust,ignore
//! use hyperstack_sdk::prelude::*;
//! use hyperstack_stacks::ore::OreStack;
//!
//! #[tokio::main]
//! async fn main() -> anyhow::Result<()> {
//!     let hs = HyperStack::<OreStack>::connect().await?;
//!     
//!     for round in hs.views.latest().listen() {
//!         println!("Round: {:?}", round);
//!     }
//!     
//!     Ok(())
//! }
//! ```

mod auth;
mod client;
mod config;
mod connection;
mod entity;
mod error;
mod frame;
pub mod prelude;
pub mod serde_utils;
mod store;
mod stream;
mod subscription;
pub mod view;

pub use auth::{AuthConfig, AuthToken, TokenTransport};
pub use client::{HyperStack, HyperStackBuilder};
pub use config::{ConnectionConfig, HyperStackConfig};
pub use connection::{ConnectionManager, ConnectionState};
pub use entity::Stack;
pub use error::{AuthErrorCode, HyperStackError, SocketIssue};
pub use frame::{
    parse_frame, parse_snapshot_entities, try_parse_subscribed_frame, Frame, Mode, Operation,
    SnapshotEntity,
};
pub use store::{deep_merge_with_append, SharedStore, StoreConfig, StoreUpdate};
pub use stream::{
    EntityStream, FilterMapStream, FilteredStream, KeyFilter, MapStream, RichEntityStream,
    RichUpdate, Update, UseStream,
};

pub use subscription::{ClientMessage, Subscription, Unsubscription};
pub use view::{
    RichWatchBuilder, StateView, UseBuilder, ViewBuilder, ViewHandle, Views, WatchBuilder,
};