Searched defs:StreamController (Results 1 – 2 of 2) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 400 pub(crate) struct StreamController { struct
403 pub(crate) io_shutdown: Arc<AtomicBool>,
404 pub(crate) io_goaway: Arc<AtomicBool>,
406 pub(crate) senders: HashMap<StreamId, BoundedSender<RespMessage>>,
407 pub(crate) curr_message: HashMap<StreamId, ManagerSendFut>,
409 pub(crate) streams: Streams,
411 pub(crate) go_away_error_code: Option<u32>,
413 pub(crate) go_away_sync: GoAwaySync,
500 controller: StreamController, in launch()
607 impl StreamController { impl
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 132 controller: StreamController, in new()
|