Searched defs:StreamController (Results 1 – 2 of 2) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 230 pub(crate) struct StreamController { struct
233 pub(crate) io_shutdown: Arc<AtomicBool>,
235 pub(crate) senders: HashMap<u32, BoundedSender<RespMessage>>,
236 pub(crate) curr_message: HashMap<u32, ManagerSendFut>,
238 pub(crate) streams: Streams,
240 pub(crate) recved_go_away: Option<u32>,
242 pub(crate) go_away_sync: GoAwaySync,
329 controller: StreamController, in launch()
437 impl StreamController { implementation
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 130 controller: StreamController, in new()
|