Trait tikv::storage::ResponseBatchConsumer[][src]

pub trait ResponseBatchConsumer<ConsumeResponse: Sized>: Send {
    fn consume(&self, id: u64, res: Result<ConsumeResponse>);
}

Required methods

fn consume(&self, id: u64, res: Result<ConsumeResponse>)[src]

Loading content...

Implementors

impl ResponseBatchConsumer<Option<Vec<u8, Global>>> for GetCommandResponseConsumer[src]

impl ResponseBatchConsumer<Option<Vec<u8, Global>>> for GetConsumer[src]

impl ResponseBatchConsumer<(Option<Vec<u8, Global>>, Statistics, PerfStatisticsDelta)> for GetCommandResponseConsumer[src]

impl ResponseBatchConsumer<(Option<Vec<u8, Global>>, Statistics, PerfStatisticsDelta)> for GetConsumer[src]

Loading content...