pub type SocketSubscriber = Receiver<Result<Option<Bytes>, ReaderSocketError>>;
pub struct SocketSubscriber { /* private fields */ }