seedlink-rs-client 0.3.1

Async SeedLink client for real-time seismic data streaming
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

//! Async SeedLink client for real-time seismic data streaming.
//!
//! Connect to SeedLink v3/v4 servers (IRIS, BMKG, GEOFON, etc.) and receive
//! miniSEED records in real-time over TCP.
//!
//! # Example
//!
//! ```no_run
//! # async fn example() -> seedlink_rs_client::Result<()> {
//! use seedlink_rs_client::SeedLinkClient;
//!
//! let mut client = SeedLinkClient::connect("rtserve.iris.washington.edu:18000").await?;
//! client.station("ANMO", "IU").await?;
//! client.select("BHZ").await?;
//! client.data().await?;
//! client.end_stream().await?;
//!
//! while let Some(frame) = client.next_frame().await? {
//!     println!("seq={}, payload={} bytes", frame.sequence(), frame.payload().len());
//! }
//! # Ok(())
//! # }
//! ```

pub(crate) mod client;
pub(crate) mod connection;
pub(crate) mod error;
#[cfg(test)]
pub(crate) mod mock;
pub(crate) mod negotiate;
pub(crate) mod reconnect;
pub(crate) mod state;
pub(crate) mod stream;

pub use client::SeedLinkClient;
pub use error::{ClientError, Result};
pub use futures_core::Stream;
pub use reconnect::{ReconnectConfig, ReconnectingClient};
pub use seedlink_rs_protocol::DataFrame;
pub use state::{ClientConfig, ClientState, OwnedFrame, ServerInfo, StationKey};
pub use stream::frame_stream;