Function read_events 

pub async fn read_events(
    stream: &mut BinlogStream,
    max_events: usize,
    timeout: Duration,
) -> Result<Vec<Event>, ConnectorError>

Reads binlog events from the stream with a timeout.

Returns up to max_events events, or fewer if the timeout expires.

Errors

Returns ConnectorError::ReadError if an I/O error occurs.