Trait kvproto::cdcpb::ChangeData

pub trait ChangeData {
    fn event_feed(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<ChangeDataRequest>, 
        sink: DuplexSink<ChangeDataEvent>
    );
}

Required methods

fn event_feed(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<ChangeDataRequest>,
    sink: DuplexSink<ChangeDataEvent>
)

Loading content...

Implementors

Loading content...