fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-06-24 07:11:38 +00:00
Code Issues Projects Releases Wiki Activity

swarm/src/lib: Rework connection exports (#2525)

Browse Source
This commit is contained in:
Max Inden
2022-02-17 21:12:37 +01:00
committed by GitHub
parent 65cc8994a6
commit eeb3504d5f
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
swarm/src/lib.rs
View File

@ -67,7 +67,10 @@ pub use behaviour::{
CloseConnection, NetworkBehaviour, NetworkBehaviourAction, NetworkBehaviourEventProcess, CloseConnection, NetworkBehaviour, NetworkBehaviourAction, NetworkBehaviourEventProcess,
NotifyHandler, PollParameters, NotifyHandler, PollParameters,
}; };
pub use connection::{PendingConnectionError, PendingInboundConnectionError}; pub use connection::{
ConnectionCounters, ConnectionError, ConnectionLimit, ConnectionLimits, PendingConnectionError,
PendingInboundConnectionError, PendingOutboundConnectionError,
};
pub use protocols_handler::{ pub use protocols_handler::{
IntoProtocolsHandler, IntoProtocolsHandlerSelect, KeepAlive, OneShotHandler, IntoProtocolsHandler, IntoProtocolsHandlerSelect, KeepAlive, OneShotHandler,
OneShotHandlerConfig, ProtocolsHandler, ProtocolsHandlerEvent, ProtocolsHandlerSelect, OneShotHandlerConfig, ProtocolsHandler, ProtocolsHandlerEvent, ProtocolsHandlerSelect,
@ -75,13 +78,8 @@ pub use protocols_handler::{
}; };
pub use registry::{AddAddressResult, AddressRecord, AddressScore}; pub use registry::{AddAddressResult, AddressRecord, AddressScore};
use crate::connection::IncomingInfo; use connection::pool::{Pool, PoolConfig, PoolEvent};
use crate::connection::{pool::PoolEvent, ListenersEvent, ListenersStream}; use connection::{EstablishedConnection, IncomingInfo, ListenersEvent, ListenersStream, Substream};
use connection::pool::{ConnectionCounters, ConnectionLimits, Pool, PoolConfig};
use connection::{
ConnectionError, ConnectionLimit, EstablishedConnection, PendingOutboundConnectionError,
Substream,
};
use dial_opts::{DialOpts, PeerCondition}; use dial_opts::{DialOpts, PeerCondition};
use either::Either; use either::Either;
use futures::{executor::ThreadPoolBuilder, prelude::*, stream::FusedStream}; use futures::{executor::ThreadPoolBuilder, prelude::*, stream::FusedStream};