1
2
3
4
5
6
7
8
9

use futures::sync::mpsc::UnboundedSender;
use std::sync::Arc;
pub(crate) use self::connection::{NatsConnSinkStream, NatsConnection};

pub(crate) mod connection;
mod connection_inner;


pub(crate) type ReconnectHandler = UnboundedSender<Arc<NatsConnection>>;