Searched refs:DynamicServiceStream (Results 1 – 3 of 3) sorted by relevance
21 pub(crate) struct DynamicServiceStream<K: Hash + Eq + Clone> { struct25 impl<K: Hash + Eq + Clone> DynamicServiceStream<K> { implementation31 impl<K: Hash + Eq + Clone> Stream for DynamicServiceStream<K> { implementation48 impl<K: Hash + Eq + Clone> Unpin for DynamicServiceStream<K> {} implementation
15 pub(super) use self::discover::DynamicServiceStream;
13 use self::service::{Connection, DynamicServiceStream, Executor, SharedExec};143 let list = DynamicServiceStream::new(rx); in balance_channel_with_executor()