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]

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][+]