Searched defs:clone_rx (Results 1 – 1 of 1) sorted by relevance
41 let clone_rx = self.rx.clone(); in stream_grpc() localVariable62 let clone_rx = self.rx.clone(); in stream_runnable() localVariable