Searched refs:RespMessage (Results 1 – 3 of 3) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 182 Pin<Box<dyn Future<Output = Result<(), SendError<RespMessage>>> + Send + Sync>>;
184 pub(crate) enum RespMessage { enum
196 pub(crate) sender: BoundedSender<RespMessage>,
235 pub(crate) senders: HashMap<u32, BoundedSender<RespMessage>>,
269 receiver: Option<BoundedReceiver<RespMessage>>,
417 let (tx, rx) = bounded_channel::<RespMessage>(self.allow_cached_frames); in send_frame_to_controller()
470 message: RespMessage, in send_message_to_stream() argument
556 RespMessage::Output(frame) => Ok(frame), in recv()
565 RespMessage::Output(frame) => Ok(frame), in recv()
589 RespMessage::Output(frame) => Poll::Ready(Ok(frame)), in poll_recv()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 27 DispatchErrorKind, OutputMessage, ReqMessage, RespMessage, SettingsState, SettingsSync,
422 RespMessage::OutputExit(error.into()), in recv_go_away_frame()
453 RespMessage::Output(frame), in recv_reset_frame()
473 RespMessage::Output(frame), in recv_header_frame()
503 RespMessage::Output(frame), in recv_data_frame()
576 RespMessage::OutputExit(DispatchErrorKind::ChannelClosed), in manage_stream_error()
749 RespMessage::OutputExit(error), in exit_with_error()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 480 .send(crate::util::dispatcher::http2::RespMessage::Output(data_1)) in ut_http2_body_poll_read()
483 .send(crate::util::dispatcher::http2::RespMessage::Output(data_2)) in ut_http2_body_poll_read()
486 .send(crate::util::dispatcher::http2::RespMessage::Output(data_3)) in ut_http2_body_poll_read()
|