Skip to content

Commit 054bbb9

Browse files
committed
refactor(body): move Sender test helper to test module
1 parent 6a6b99f commit 054bbb9

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

src/body/incoming.rs

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -350,11 +350,6 @@ impl Sender {
350350
}
351351
}
352352

353-
#[cfg(test)]
354-
async fn ready(&mut self) -> crate::Result<()> {
355-
futures_util::future::poll_fn(|cx| self.poll_ready(cx)).await
356-
}
357-
358353
/// Send trailers on trailers channel.
359354
#[allow(unused)]
360355
pub(crate) async fn send_trailers(&mut self, trailers: HeaderMap) -> crate::Result<()> {
@@ -384,11 +379,6 @@ impl Sender {
384379
.map_err(|err| err.into_inner().expect("just sent Ok"))
385380
}
386381

387-
#[cfg(test)]
388-
pub(crate) fn abort(mut self) {
389-
self.send_error(crate::Error::new_body_write_aborted());
390-
}
391-
392382
pub(crate) fn send_error(&mut self, err: crate::Error) {
393383
let _ = self
394384
.data_tx
@@ -424,6 +414,16 @@ mod tests {
424414
use super::{Body, DecodedLength, Incoming, Sender, SizeHint};
425415
use http_body_util::BodyExt;
426416

417+
impl Sender {
418+
async fn ready(&mut self) -> crate::Result<()> {
419+
futures_util::future::poll_fn(|cx| self.poll_ready(cx)).await
420+
}
421+
422+
fn abort(mut self) {
423+
self.send_error(crate::Error::new_body_write_aborted());
424+
}
425+
}
426+
427427
#[test]
428428
fn test_size_of() {
429429
// These are mostly to help catch *accidentally* increasing

0 commit comments

Comments
 (0)