actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-02-25 15:02:50 +01:00
Code Issues Releases Wiki Activity

changes

Browse Source
This commit is contained in:
Nikolay Kim 2019-03-13 14:38:33 -07:00
parent 8b0fe6f796
commit 87db4bf741
4 changed files with 6 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
actix-connect/CHANGES.md
View File

@ -1,28 +1,7 @@
# Changes # Changes
## [0.3.0] - 2019-03-02 ## [0.1.0] - 2019-03-xx
### Changed * Refactor resolver and connector services
* Migrate to actix-service 0.3 * Rename crate
## [0.2.0] - 2019-02-01
### Changed
* Migrate to actix-service 0.2
* Upgrade trust-dns-resolver
* Use tokio-current-thread instead of direct actix-rt dipendency
## [0.1.1] - 2019-01-13
* Upgrade trust-dns-proto
## [0.1.0] - 2018-12-09
* Move server to separate crate

2
actix-connect/Cargo.toml
View File

@ -17,7 +17,7 @@ workspace = ".."
features = ["ssl"] features = ["ssl"]
[lib] [lib]
name = "actix_connector" name = "actix_connect"
path = "src/lib.rs" path = "src/lib.rs"
[features] [features]

2
actix-connect/src/connector.rs
View File

@ -96,7 +96,7 @@ impl Future for ConnectorResponse {
"TCP connector - successfully connected to connecting to {:?} - {:?}", "TCP connector - successfully connected to connecting to {:?} - {:?}",
host, sock.peer_addr() host, sock.peer_addr()
); );
return Ok(Async::Ready(Stream::new(sock, self.host.take().unwrap()))); return Ok(Async::Ready(Stream::new(sock, host)));
} }
Ok(Async::NotReady) => return Ok(Async::NotReady), Ok(Async::NotReady) => return Ok(Async::NotReady),
Err(err) => { Err(err) => {

6
actix-connect/src/error.rs
View File

@ -13,10 +13,6 @@ pub enum ConnectError {
#[display(fmt = "No dns records found for the input")] #[display(fmt = "No dns records found for the input")]
NoRecords, NoRecords,
/// Connecting took too long
#[display(fmt = "Timeout out while establishing connection")]
Timeout,
/// Invalid input /// Invalid input
InvalidInput, InvalidInput,
@ -26,5 +22,5 @@ pub enum ConnectError {
/// Connection io error /// Connection io error
#[display(fmt = "{}", _0)] #[display(fmt = "{}", _0)]
IoError(io::Error), Io(io::Error),
} }