|
1 | 1 | #![allow(dead_code)]
|
2 |
| -#[cfg(feature = "async_std")] |
3 |
| -mod noise_connection_async_std; |
4 |
| -#[cfg(feature = "async_std")] |
5 |
| -mod plain_connection_async_std; |
6 | 2 | use binary_sv2::{Deserialize, GetSize, Serialize};
|
7 |
| -#[cfg(feature = "async_std")] |
8 |
| -pub use noise_connection_async_std::{connect, listen, Connection}; |
9 |
| -#[cfg(feature = "async_std")] |
10 |
| -pub use plain_connection_async_std::{plain_connect, plain_listen, PlainConnection}; |
11 |
| - |
12 |
| -#[cfg(feature = "tokio")] |
13 |
| -pub mod noise_connection_tokio; |
14 |
| -#[cfg(feature = "tokio")] |
| 3 | + |
| 4 | +pub mod noise_connection; |
15 | 5 | pub mod noise_connection_tokio_with_tokio_channels;
|
16 |
| -#[cfg(feature = "tokio")] |
17 |
| -pub mod plain_connection_tokio; |
| 6 | +pub mod plain_connection; |
18 | 7 |
|
19 | 8 | use async_channel::{Receiver, RecvError, SendError, Sender};
|
20 | 9 | use codec_sv2::{Error as CodecError, HandShakeFrame, HandshakeRole, StandardEitherFrame};
|
@@ -56,14 +45,12 @@ impl<T> From<SendError<T>> for Error {
|
56 | 45 | }
|
57 | 46 | }
|
58 | 47 |
|
59 |
| -#[cfg(feature = "tokio")] |
60 | 48 | impl<T> From<tokio::sync::broadcast::error::SendError<T>> for Error {
|
61 | 49 | fn from(_: tokio::sync::broadcast::error::SendError<T>) -> Self {
|
62 | 50 | Error::SendErrorTokio
|
63 | 51 | }
|
64 | 52 | }
|
65 | 53 |
|
66 |
| -#[cfg(feature = "tokio")] |
67 | 54 | impl From<tokio::sync::broadcast::error::RecvError> for Error {
|
68 | 55 | fn from(_: tokio::sync::broadcast::error::RecvError) -> Self {
|
69 | 56 | Error::RecvErrorTokio
|
|
0 commit comments