Skip to content

Commit ccefbeb

Browse files
authored
Refactor: update use of compression_core::assert_* (#375)
* Refactor tokio/write/encoder.rs Rm unnecessary fm definition Signed-off-by: Jiahao XU <[email protected]> * Refactor decoder.rs Signed-off-by: Jiahao XU <[email protected]> * Refactor encoder.rs Signed-off-by: Jiahao XU <[email protected]> * Refactor decoder.rs Signed-off-by: Jiahao XU <[email protected]> * Refactor encoder.rs Signed-off-by: Jiahao XU <[email protected]> * Refactor decoder.rs Signed-off-by: Jiahao XU <[email protected]> * refactor encoder.rs Signed-off-by: Jiahao XU <[email protected]> * Refactor decoder.rs Signed-off-by: Jiahao XU <[email protected]> * Fix tokio/write/macros/decoder.rs Add back missing { Signed-off-by: Jiahao XU <[email protected]> --------- Signed-off-by: Jiahao XU <[email protected]>
1 parent 776b25f commit ccefbeb

File tree

8 files changed

+40
-56
lines changed

8 files changed

+40
-56
lines changed

src/futures/bufread/macros/decoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -115,14 +115,12 @@ macro_rules! decoder {
115115
}
116116

117117
const _: () = {
118-
fn _assert() {
119-
use crate::core::util::{_assert_send, _assert_sync};
120-
use core::pin::Pin;
121-
use futures_io::AsyncBufRead;
118+
use crate::core::util::{_assert_send, _assert_sync};
119+
use core::pin::Pin;
120+
use futures_io::AsyncBufRead;
122121

123-
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
124-
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
125-
}
122+
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
123+
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
126124
};
127125
}
128126
}

src/futures/bufread/macros/encoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -103,14 +103,12 @@ macro_rules! encoder {
103103
}
104104

105105
const _: () = {
106-
fn _assert() {
107-
use crate::core::util::{_assert_send, _assert_sync};
108-
use core::pin::Pin;
109-
use futures_io::AsyncBufRead;
106+
use crate::core::util::{_assert_send, _assert_sync};
107+
use core::pin::Pin;
108+
use futures_io::AsyncBufRead;
110109

111-
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
112-
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
113-
}
110+
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
111+
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
114112
};
115113
}
116114
}

src/futures/write/macros/decoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -121,14 +121,12 @@ macro_rules! decoder {
121121
}
122122

123123
const _: () = {
124-
fn _assert() {
125-
use crate::core::util::{_assert_send, _assert_sync};
126-
use core::pin::Pin;
127-
use futures_io::AsyncWrite;
124+
use crate::core::util::{_assert_send, _assert_sync};
125+
use core::pin::Pin;
126+
use futures_io::AsyncWrite;
128127

129-
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
130-
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
131-
}
128+
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
129+
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
132130
};
133131
}
134132
}

src/futures/write/macros/encoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -118,14 +118,12 @@ macro_rules! encoder {
118118
}
119119

120120
const _: () = {
121-
fn _assert() {
122-
use crate::core::util::{_assert_send, _assert_sync};
123-
use core::pin::Pin;
124-
use futures_io::AsyncWrite;
121+
use crate::core::util::{_assert_send, _assert_sync};
122+
use core::pin::Pin;
123+
use futures_io::AsyncWrite;
125124

126-
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
127-
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
128-
}
125+
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
126+
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
129127
};
130128
}
131129
}

src/tokio/bufread/macros/decoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -119,14 +119,12 @@ macro_rules! decoder {
119119
}
120120

121121
const _: () = {
122-
fn _assert() {
123-
use crate::core::util::{_assert_send, _assert_sync};
124-
use core::pin::Pin;
125-
use tokio::io::AsyncBufRead;
122+
use crate::core::util::{_assert_send, _assert_sync};
123+
use core::pin::Pin;
124+
use tokio::io::AsyncBufRead;
126125

127-
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
128-
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
129-
}
126+
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
127+
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
130128
};
131129
}
132130
}

src/tokio/bufread/macros/encoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -109,14 +109,12 @@ macro_rules! encoder {
109109
}
110110

111111
const _: () = {
112-
fn _assert() {
113-
use crate::core::util::{_assert_send, _assert_sync};
114-
use core::pin::Pin;
115-
use tokio::io::AsyncBufRead;
112+
use crate::core::util::{_assert_send, _assert_sync};
113+
use core::pin::Pin;
114+
use tokio::io::AsyncBufRead;
116115

117-
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
118-
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
119-
}
116+
_assert_send::<$name<Pin<Box<dyn AsyncBufRead + Send>>>>();
117+
_assert_sync::<$name<Pin<Box<dyn AsyncBufRead + Sync>>>>();
120118
};
121119
}
122120
}

src/tokio/write/macros/decoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -113,14 +113,12 @@ macro_rules! decoder {
113113
}
114114

115115
const _: () = {
116-
fn _assert() {
117-
use crate::core::util::{_assert_send, _assert_sync};
118-
use core::pin::Pin;
119-
use tokio::io::AsyncWrite;
116+
use crate::core::util::{_assert_send, _assert_sync};
117+
use core::pin::Pin;
118+
use tokio::io::AsyncWrite;
120119

121-
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
122-
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
123-
}
120+
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
121+
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
124122
};
125123
}
126124
}

src/tokio/write/macros/encoder.rs

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -110,14 +110,12 @@ macro_rules! encoder {
110110
}
111111

112112
const _: () = {
113-
fn _assert() {
114-
use crate::core::util::{_assert_send, _assert_sync};
115-
use core::pin::Pin;
116-
use tokio::io::AsyncWrite;
113+
use crate::core::util::{_assert_send, _assert_sync};
114+
use core::pin::Pin;
115+
use tokio::io::AsyncWrite;
117116

118-
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
119-
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
120-
}
117+
_assert_send::<$name<Pin<Box<dyn AsyncWrite + Send>>>>();
118+
_assert_sync::<$name<Pin<Box<dyn AsyncWrite + Sync>>>>();
121119
};
122120
}
123121
}

0 commit comments

Comments
 (0)