diff --git a/CHANGELOG.md b/CHANGELOG.md index dba28e2..30bc9de 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,9 @@ ## unreleased +## v0.0.4 (2021-06-28) + +* bugfix: Retina stopped receiving packets after receiving a keepalive response. + ## v0.0.3 (2021-06-28) * BREAKING CHANGE: `Session` now directly implements `Stream` instead of diff --git a/Cargo.lock b/Cargo.lock index 5d09af3..fcf9f69 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -32,27 +32,6 @@ version = "0.5.2" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "23b62fc65de8e4e7f52534fb52b0f3ed04746ae267519eef2a83941e8085068b" -[[package]] -name = "async-stream" -version = "0.3.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "171374e7e3b2504e0e5236e3b59260560f9fe94bfe9ac39ba5e4e929c5590625" -dependencies = [ - "async-stream-impl", - "futures-core", -] - -[[package]] -name = "async-stream-impl" -version = "0.3.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "648ed8c8d2ce5409ccd57453d9d1b214b342a0d69376a6feda1fd6cae3299308" -dependencies = [ - "proc-macro2", - "quote", - "syn", -] - [[package]] name = "atty" version = "0.2.14" @@ -1087,9 +1066,8 @@ checksum = "f497285884f3fcff424ffc933e56d7cbca511def0c9831a7f9b5f6153e3cc89b" [[package]] name = "retina" -version = "0.0.3" +version = "0.0.4" dependencies = [ - "async-stream", "base64", "bitreader", "bytes", diff --git a/Cargo.toml b/Cargo.toml index 5ee2be3..64faf1c 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "retina" -version = "0.0.3" +version = "0.0.4" authors = ["Scott Lamb "] license = "MIT/Apache-2.0" edition = "2018" @@ -11,7 +11,6 @@ repository = "https://github.com/scottlamb/retina" include = ["src/**/*", "benches", "Cargo.toml"] [dependencies] -async-stream = "0.3.1" base64 = "0.13.0" bitreader = "0.3.3" bytes = "1.0.1" diff --git a/src/client/mod.rs b/src/client/mod.rs index ec490c9..269f452 100644 --- a/src/client/mod.rs +++ b/src/client/mod.rs @@ -767,6 +767,7 @@ impl futures::Stream for Session { if let Err(e) = Session::handle_response(&mut state, response) { return Poll::Ready(Some(Err(e))); } + continue; } rtsp_types::Message::Request(request) => { warn!("Received RTSP request in Playing state. Responding unimplemented.\n{:#?}",