Method stream_commit

src/moonlink/src/table_handler/test_utils.rs:276–284

(&self, lsn: u64, xact_id: u32)

    }

    pub async fn stream_commit(&self, lsn: u64, xact_id: u32) -> TableEvent {
        let event = TableEvent::Commit {
            lsn,
            xact_id: Some(xact_id),
            is_recovery: false,
        };
        self.send_event(event.clone()).await;
        event
    }

    pub async fn stream_abort(&self, xact_id: u32) -> TableEvent {
        let event = TableEvent::StreamAbort {