pub async fn new(stream: T, is_initiator: bool)
        -> Result<(Self, ReplicationHandle)>
    {
        Self::with_options(stream, Options {
            is_initiator,
            ..Options::default()
        }).await
    }
/// Create `Replication` and wait for protocol handshake.
Create `Replication` and wait for protocol handshake.
Create ` Replication ` and wait for protocol handshake .
pub async fn new(stream: T, is_initiator: bool)
        -> Result<(Self, ReplicationHandle)>
    {
        Self::with_options(stream, Options {
            is_initiator,
            ..Options::default()
        }).await
    }
pub async fn new ( stream : T , is_initiator : bool ) -> Result < ( Self , ReplicationHandle ) > { Self :: with_options ( stream , Options { is_initiator , .. Options :: default ( ) } ) . await }
Create `Replication` and wait for protocol handshake.
Create ` Replication ` and wait for protocol handshake .
stream
T
is_initiator
bool
stream
T
is_initiator
bool