Searched defs:StreamController (Results 1 – 2 of 2) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 361 pub(crate) struct StreamController { struct
364 pub(crate) io_shutdown: Arc<AtomicBool>,
365 pub(crate) io_goaway: Arc<AtomicBool>,
367 pub(crate) senders: HashMap<StreamId, BoundedSender<RespMessage>>,
368 pub(crate) curr_message: HashMap<StreamId, ManagerSendFut>,
370 pub(crate) streams: Streams,
372 pub(crate) go_away_error_code: Option<u32>,
374 pub(crate) go_away_sync: GoAwaySync,
461 controller: StreamController, in launch()
567 impl StreamController { impl
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 132 controller: StreamController, in new()
|