#[cfg(any(feature = "indexer_stream", feature = "relay", feature = "jetstream"))]
pub(crate) mod engine;
#[cfg(any(feature = "indexer_stream", feature = "relay", feature = "jetstream"))]
pub(crate) mod replay_cap;
#[cfg(any(feature = "indexer_stream", feature = "relay", feature = "jetstream"))]
pub(crate) mod types;

#[cfg(feature = "indexer_stream")]
pub(crate) mod chunks;
#[cfg(feature = "indexer_stream")]
pub(crate) mod indexer;
#[cfg(feature = "indexer_stream")]
pub(super) use indexer::{Decoded, Frame, event_stream_thread};

#[cfg(feature = "relay")]
pub(crate) mod relay;
#[cfg(feature = "relay")]
pub(super) use relay::relay_stream_thread;

#[cfg(feature = "jetstream")]
pub(crate) mod jetstream;
#[cfg(feature = "jetstream")]
pub(super) use jetstream::jetstream_stream_thread;
#[cfg(feature = "jetstream")]
pub(crate) use jetstream::{
    JetstreamAccount, JetstreamCommit, JetstreamEvent, JetstreamIdentity, JetstreamPayload,
};

#[cfg(any(feature = "indexer_stream", feature = "relay", feature = "jetstream"))]
pub(crate) use engine::*;
#[cfg(any(feature = "indexer_stream", feature = "relay", feature = "jetstream"))]
pub(crate) use types::*;

#[cfg(all(test, feature = "indexer_stream"))]
mod interleaving;