pub fn new(io: T, options: Options) -> Self {
        let mut io = IO::new(io, options);
        io.read_state.set_frame_type(FrameType::Raw);

        Self {
            io,
            state: Stage {
                handshake: None,
            },
        }
    }
/// Create a new replication protocol in handshake stage.
Create a new replication protocol in handshake stage.
Create a new replication protocol in handshake stage .
pub fn new(io: T, options: Options) -> Self {
        let mut io = IO::new(io, options);
        io.read_state.set_frame_type(FrameType::Raw);
        Self {
            io,
            state: Stage {
                handshake: None,
            },
        }
    }
pub fn new ( io : T , options : Options ) -> Self { let mut io = IO :: new ( io , options ) ; io . read_state . set_frame_type ( FrameType :: Raw ) ; Self { io , state : Stage { handshake : None , } , } }
Create a new replication protocol in handshake stage.
Create a new replication protocol in handshake stage .
io
T
options
Options
io
T
options
Options