Searched refs:producer_ (Results 1 – 4 of 4) sorted by relevance
24 producer_(producer) { in ConsumerChannel()51 return std::static_pointer_cast<ProducerChannel>(producer_.lock()); in GetProducer()174 producer_.reset(); in OnProducerClosed()
18 producer_(producer), in ConsumerQueueChannel()64 return std::static_pointer_cast<ProducerQueueChannel>(producer_.lock()); in GetProducer()161 producer_.reset(); in OnProducerClosed()
45 std::weak_ptr<Channel> producer_; variable
63 std::weak_ptr<Channel> producer_; variable