Struct TopicReader 

pub struct TopicReader { /* private fields */ }

Implementations

impl TopicReader

pub async fn read_batch(&mut self) -> YdbResult<TopicReaderBatch>

pub async fn pop_batch_in_tx( &mut self, tx: &mut Box<dyn Transaction>, ) -> YdbResult<TopicReaderBatch>

Read a batch of messages within a transaction context. The TopicReaderBatch from the result will be committed within the tx transaction. This is an EXAMPLE of the interface. IT IS NOT PRODUCTION READY. The reader will fail consistently on ANY error, including TLI.

You can use this method to test the interface and try writing your own code to see how it works. DO NOT USE IN PRODUCTION

pub fn commit( &mut self, commit_marker: TopicReaderCommitMarker, ) -> YdbResult<()>

Trait Implementations

impl Drop for TopicReader

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.