emergent-client 0.13.1

Client library for Emergent event-based workflow platform
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

//! Convenient re-exports for common usage.
//!
//! This module provides a single import for the most commonly used types:
//!
//! ```rust,ignore
//! use emergent_client::prelude::*;
//!
//! let sink = EmergentSink::connect("my_sink").await?;
//! let mut stream = sink.subscribe(["timer.tick"]).await?;
//!
//! while let Some(msg) = stream.next().await {
//!     let payload: MyPayload = msg.payload_as()?;
//!     println!("Received: {:?}", payload);
//! }
//! ```

pub use crate::Result;
pub use crate::connection::{EmergentHandler, EmergentSink, EmergentSource};
pub use crate::error::ClientError;
pub use crate::message::{EmergentMessage, create_message};
pub use crate::stream::MessageStream;
pub use crate::subscribe::IntoSubscription;
pub use crate::types::{SystemEventPayload, SystemShutdownPayload};

// Re-export StreamExt for convenient stream operations
pub use futures::StreamExt;