Searched refs:sink_base (Results 1 – 1 of 1) sorted by relevance
318 sink_base: SinkBase, field327 sink_base: SinkBase::new(false), in new()343 self.sink_base.enhance_buffer_strategy = flag; in enhance_batch()369 Pin::new(&mut self.sink_base).poll_ready(cx) in poll_ready()379 Pin::new(&mut t.sink_base).start_send(&mut t.call, &msg, flags, t.req_ser) in start_send()389 Pin::new(&mut t.sink_base).poll_flush(cx, &mut t.call) in poll_flush()396 ready!(Pin::new(&mut t.sink_base).poll_ready(cx)?); in poll_close()