prepare bytestring release 1.3.0

see RUSTSEC-2023-0001

part of actix/actix-web#2962

.cargo/config.toml

@@ -20,4 +20,4 @@ ci-test = "hack --feature-powerset --exclude-features=io-uring test --lib --test
 ci-test-win = "hack --feature-powerset --depth 2 --exclude-features=io-uring test --lib --tests --no-fail-fast -- --nocapture"
 
 # test with io-uring feature
-ci-test-linux = "    hack --feature-powerset test --lib --tests --no-fail-fast -- --nocapture"
+ci-test-linux = "hack --feature-powerset test --lib --tests --no-fail-fast -- --nocapture"

.github/workflows/ci-master.yml

@@ -29,7 +29,7 @@ jobs:
         if: matrix.target.os == 'macos-latest'
         run: sudo ifconfig lo0 alias 127.0.0.3
 
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       # install OpenSSL on Windows
       - name: Set vcpkg root
@@ -43,11 +43,10 @@ jobs:
         run: vcpkg install openssl:x86-windows
 
       - name: Install ${{ matrix.version }}
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: ${{ matrix.version }}-${{ matrix.target.triple }}
-          profile: minimal
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install ${{ matrix.version }}-${{ matrix.target.triple }}
+          rustup override set ${{ matrix.version }}-${{ matrix.target.triple }}
 
       # - name: Install MSYS2
       #   if: matrix.target.triple == 'x86_64-pc-windows-gnu'
@@ -59,43 +58,34 @@ jobs:
       #     msys2 -c 'pacman --noconfirm -S base-devel pkg-config'
 
       # - name: Generate Cargo.lock
-      #   uses: actions-rs/cargo@v1
-      #   with: { command: generate-lockfile }
+      #   run: cargo generate-lockfile
       # - name: Cache Dependencies
-      #   uses: Swatinem/rust-cache@v1.2.0
+      #   uses: Swatinem/rust-cache@v2.2.0
 
       - name: Install cargo-hack
-        uses: actions-rs/cargo@v1
-        with:
-          command: install
-          args: cargo-hack
+        run: cargo install cargo-hack
 
       - name: check lib
         if: >
           matrix.target.os != 'ubuntu-latest'
           && matrix.target.triple != 'x86_64-pc-windows-gnu'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-lib }
+        run: cargo ci-check-lib
       - name: check lib
         if: matrix.target.os == 'ubuntu-latest'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-lib-linux }
+        run: cargo ci-check-lib-linux
       - name: check lib
         if: matrix.target.triple == 'x86_64-pc-windows-gnu'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-min }
+        run: cargo ci-check-min
 
       - name: check full
         # TODO: compile OpenSSL and run tests on MinGW
         if: >
           matrix.target.os != 'ubuntu-latest'
           && matrix.target.triple != 'x86_64-pc-windows-gnu'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check }
+        run: cargo ci-check
       - name: check all
         if: matrix.target.os == 'ubuntu-latest'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-linux }
+        run: cargo ci-check-linux
 
       - name: tests
         if: >
@@ -116,20 +106,18 @@ jobs:
     name: coverage
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Install Rust (nightly)
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: nightly
-          profile: minimal
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install nightly
+          rustup override set nightly
 
       - name: Generate Cargo.lock
-        uses: actions-rs/cargo@v1
-        with: { command: generate-lockfile }
+        run: cargo generate-lockfile
       - name: Cache Dependencies
-        uses: Swatinem/rust-cache@v1.3.0
+        uses: Swatinem/rust-cache@v2.2.0
 
       - name: Generate coverage file
         if: github.ref == 'refs/heads/master'
@@ -138,73 +126,54 @@ jobs:
           cargo tarpaulin --out Xml --verbose
       - name: Upload to Codecov
         if: github.ref == 'refs/heads/master'
-        uses: codecov/codecov-action@v1
-        with: { file: cobertura.xml }
+        uses: codecov/codecov-action@v3
+        with: { files: cobertura.xml }
 
   minimal-versions:
     name: minimal versions
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Install Rust (nightly)
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: nightly
-          profile: minimal
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install nightly
+          rustup override set nightly
 
       - name: Generate Cargo.lock
-        uses: actions-rs/cargo@v1
-        with: { command: generate-lockfile }
+        run: cargo generate-lockfile
       - name: Cache Dependencies
-        uses: Swatinem/rust-cache@v1.3.0
+        uses: Swatinem/rust-cache@v2.2.0
 
       - name: Install cargo-minimal-versions
-        uses: actions-rs/cargo@v1
-        with:
-          command: install
-          args: cargo-minimal-versions
+        run: cargo install cargo-minimal-versions
 
       - name: Install cargo-hack
-        uses: actions-rs/cargo@v1
-        with:
-          command: install
-          args: cargo-hack
+        run: cargo install cargo-hack
 
       - name: Check With Minimal Versions
-        uses: actions-rs/cargo@v1
-        with:
-          command: minimal-versions
-          args: check
+        run: cargo minimal-versions check
 
   nextest:
     name: nextest
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Install Rust
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: stable
-          profile: minimal
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install stable
+          rustup override set stable
 
       - name: Generate Cargo.lock
-        uses: actions-rs/cargo@v1
-        with: { command: generate-lockfile }
+        run: cargo generate-lockfile
       - name: Cache Dependencies
-        uses: Swatinem/rust-cache@v1.3.0
+        uses: Swatinem/rust-cache@v2.2.0
 
       - name: Install cargo-nextest
-        uses: actions-rs/cargo@v1
-        with:
-          command: install
-          args: cargo-nextest
+        run: cargo install cargo-nextest
 
       - name: Test with cargo-nextest
-        uses: actions-rs/cargo@v1
-        with:
-          command: nextest
-          args: run
+        run: cargo nextest run

.github/workflows/ci.yml

@@ -18,7 +18,7 @@ jobs:
           - { name: Windows (MinGW), os: windows-latest, triple: x86_64-pc-windows-gnu }
           - { name: Windows (32-bit), os: windows-latest, triple: i686-pc-windows-msvc }
         version:
-          - 1.57.0
+          - 1.59.0
           - stable
 
     name: ${{ matrix.target.name }} / ${{ matrix.version }}
@@ -32,7 +32,7 @@ jobs:
         if: matrix.target.os == 'macos-latest'
         run: sudo ifconfig lo0 alias 127.0.0.3
 
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       # install OpenSSL on Windows
       - name: Set vcpkg root
@@ -46,11 +46,10 @@ jobs:
         run: vcpkg install openssl:x86-windows
 
       - name: Install ${{ matrix.version }}
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: ${{ matrix.version }}-${{ matrix.target.triple }}
-          profile: minimal
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install ${{ matrix.version }}-${{ matrix.target.triple }}
+          rustup override set ${{ matrix.version }}-${{ matrix.target.triple }}
 
       # - name: Install MSYS2
       #   if: matrix.target.triple == 'x86_64-pc-windows-gnu'
@@ -62,47 +61,55 @@ jobs:
       #     msys2 -c 'pacman --noconfirm -S base-devel pkg-config'
 
       # - name: Generate Cargo.lock
-      #   uses: actions-rs/cargo@v1
-      #   with: { command: generate-lockfile }
+      #   run: cargo generate-lockfile
       # - name: Cache Dependencies
-      #   uses: Swatinem/rust-cache@v1.2.0
+      #   uses: Swatinem/rust-cache@v2.2.0
 
       - name: Install cargo-hack
-        uses: actions-rs/cargo@v1
-        with:
-          command: install
-          args: cargo-hack
+        if: matrix.version != '1.59.0'
+        run: cargo install cargo-hack
+
+      # newer cargo-hack versions require 1.60 or above
+      - name: Install cargo-hack (1.59.0)
+        if: matrix.version == '1.59.0'
+        run: cargo install cargo-hack --version=0.5.21
+
+      - name: workaround MSRV issues
+        if: matrix.version == '1.59.0'
+        run: |
+          cargo install cargo-edit --version=0.8.0
+          cargo add env_logger@0.9 --dev -p=actix-tls
+          cargo add env_logger@0.9 --dev -p=actix-server
 
       - name: Generate Cargo.lock
-        uses: actions-rs/cargo@v1
-        with: { command: generate-lockfile }
+        run: cargo generate-lockfile
+
+      - name: workaround MSRV issues
+        if: matrix.version != 'stable'
+        run: |
+          cargo update -p=time --precise=0.3.13  # time is only a dev dep so shouldn't affect msrv
 
       - name: check lib
         if: >
           matrix.target.os != 'ubuntu-latest'
           && matrix.target.triple != 'x86_64-pc-windows-gnu'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-lib }
+        run: cargo ci-check-lib
       - name: check lib
         if: matrix.target.os == 'ubuntu-latest'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-lib-linux }
+        run: cargo ci-check-lib-linux
       - name: check lib
         if: matrix.target.triple == 'x86_64-pc-windows-gnu'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-min }
+        run: cargo ci-check-min
 
       - name: check full
         # TODO: compile OpenSSL and run tests on MinGW
         if: >
           matrix.target.os != 'ubuntu-latest'
           && matrix.target.triple != 'x86_64-pc-windows-gnu'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check }
+        run: cargo ci-check
       - name: check all
         if: matrix.target.os == 'ubuntu-latest'
-        uses: actions-rs/cargo@v1
-        with: { command: ci-check-linux }
+        run: cargo ci-check-linux
 
       - name: tests
         if: matrix.target.os == 'macos-latest'
@@ -118,6 +125,7 @@ jobs:
           sudo bash -c "ulimit -Sl 512 && ulimit -Hl 512 && PATH=$PATH:/usr/share/rust/.cargo/bin && RUSTUP_TOOLCHAIN=${{ matrix.version }} cargo ci-test && RUSTUP_TOOLCHAIN=${{ matrix.version }} cargo ci-test-linux"
 
       - name: Clear the cargo caches
+        if: matrix.version == 'stable' # MSRV(1.58) cargo-cache now fails to install on 1.59
         run: |
           cargo install cargo-cache --version 0.6.2 --no-default-features --features ci-autoclean
           cargo-cache
@@ -127,20 +135,18 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Install Rust (nightly)
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: nightly-x86_64-unknown-linux-gnu
-          profile: minimal
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install nightly
+          rustup override set nightly
 
       - name: Generate Cargo.lock
-        uses: actions-rs/cargo@v1
-        with: { command: generate-lockfile }
+        run: cargo generate-lockfile
       - name: Cache Dependencies
-        uses: Swatinem/rust-cache@v1.3.0
+        uses: Swatinem/rust-cache@v2.2.0
 
       - name: doc tests io-uring
         run: |

.github/workflows/clippy-fmt.yml

@@ -8,35 +8,30 @@ jobs:
   fmt:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Install Rust
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: stable
-          profile: minimal
-          components: rustfmt
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install stable
+          rustup override set stable
+          rustup component add rustfmt
       - name: Rustfmt Check
-        uses: actions-rs/cargo@v1
-        with:
-          command: fmt
-          args: --all -- --check
+        run: cargo fmt --all -- --check
 
   clippy:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Install Rust
-        uses: actions-rs/toolchain@v1
+        run: |
+          rustup set profile minimal
+          rustup install stable
+          rustup override set stable
+          rustup component add clippy
+      - uses: giraffate/clippy-action@v1
         with:
-          toolchain: stable
-          profile: minimal
-          components: clippy
-          override: true
-      - name: Clippy Check
-        uses: actions-rs/clippy-check@v1
-        with:
-          token: ${{ secrets.GITHUB_TOKEN }}
-          args: --workspace --all-features --tests --examples --bins -- -Dclippy::todo
+          reporter: "github-pr-check"
+          github_token: ${{ secrets.GITHUB_TOKEN }}
+          clippy_flags: --workspace --all-features --tests --examples --bins -- -Dclippy::todo

.github/workflows/upload-doc.yml

@@ -9,27 +9,21 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Install Rust
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: nightly-x86_64-unknown-linux-gnu
-          profile: minimal
-          override: true
+        run: |
+          rustup set profile minimal
+          rustup install nightly
+          rustup override set nightly
 
       - name: Build Docs
-        uses: actions-rs/cargo@v1
-        with:
-          command: doc
-          args: --workspace --all-features --no-deps
+        run: cargo doc --workspace --all-features --no-deps
 
       - name: Tweak HTML
         run: echo '<meta http-equiv="refresh" content="0;url=actix_server/index.html">' > target/doc/index.html
 
       - name: Deploy to GitHub Pages
-        uses: JamesIves/github-pages-deploy-action@3.7.1
+        uses: JamesIves/github-pages-deploy-action@v4
         with:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-          BRANCH: gh-pages
-          FOLDER: target/doc
+          folder: target/doc

CODE_OF_CONDUCT.md

@@ -8,19 +8,19 @@ In the interest of fostering an open and welcoming environment, we as contributo
 
 Examples of behavior that contributes to creating a positive environment include:
 
-* Using welcoming and inclusive language
-* Being respectful of differing viewpoints and experiences
-* Gracefully accepting constructive criticism
-* Focusing on what is best for the community
-* Showing empathy towards other community members
+- Using welcoming and inclusive language
+- Being respectful of differing viewpoints and experiences
+- Gracefully accepting constructive criticism
+- Focusing on what is best for the community
+- Showing empathy towards other community members
 
 Examples of unacceptable behavior by participants include:
 
-* The use of sexualized language or imagery and unwelcome sexual attention or advances
-* Trolling, insulting/derogatory comments, and personal or political attacks
-* Public or private harassment
-* Publishing others' private information, such as a physical or electronic address, without explicit permission
-* Other conduct which could reasonably be considered inappropriate in a professional setting
+- The use of sexualized language or imagery and unwelcome sexual attention or advances
+- Trolling, insulting/derogatory comments, and personal or political attacks
+- Public or private harassment
+- Publishing others' private information, such as a physical or electronic address, without explicit permission
+- Other conduct which could reasonably be considered inappropriate in a professional setting
 
 ## Our Responsibilities
 
@@ -39,7 +39,7 @@ Instances of abusive, harassing, or otherwise unacceptable behavior may be repor
 Project maintainers who do not follow or enforce the Code of Conduct in good faith may face temporary or permanent repercussions as determined by other members of the project's leadership.
 
 [@robjtede]: https://github.com/robjtede
-[@JohnTitor]: https://github.com/JohnTitor
+[@johntitor]: https://github.com/JohnTitor
 
 ## Attribution
 

README.md

@@ -13,7 +13,7 @@ See example folders for [`actix-server`](./actix-server/examples) and [`actix-tl
 
 ## MSRV
 
-Most crates in this repo's have a Minimum Supported Rust Version (MSRV) of 1.49.0. Only `actix-tls` and `actix-server` have MSRV of 1.54.0. As a policy, we permit MSRV increases in non-breaking releases.
+Crates in this repo currently have a Minimum Supported Rust Version (MSRV) of 1.59. As a policy, we permit MSRV increases in non-breaking releases.
 
 ## License
 

actix-codec/CHANGES.md

@@ -1,39 +1,40 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 0.5.1 - 2022-03-15
+
 - Logs emitted now use the `tracing` crate with `log` compatibility. [#451]
 - Minimum supported Rust version (MSRV) is now 1.49.
 
 [#451]: https://github.com/actix/actix-net/pull/451
 
-
 ## 0.5.0 - 2022-02-15
+
 - Updated `tokio-util` dependency to `0.7.0`. [#446]
 
 [#446]: https://github.com/actix/actix-net/pull/446
 
-
 ## 0.4.2 - 2021-12-31
+
 - No significant changes since `0.4.1`.
 
-
 ## 0.4.1 - 2021-11-05
+
 - Added `LinesCodec.` [#338]
 - `Framed::poll_ready` flushes when the buffer is full. [#409]
 
 [#338]: https://github.com/actix/actix-net/pull/338
 [#409]: https://github.com/actix/actix-net/pull/409
 
-
 ## 0.4.0 - 2021-04-20
+
 - No significant changes since v0.4.0-beta.1.
 
-
 ## 0.4.0-beta.1 - 2020-12-28
+
 - Replace `pin-project` with `pin-project-lite`. [#237]
 - Upgrade `tokio` dependency to `1`. [#237]
 - Upgrade `tokio-util` dependency to `0.6`. [#237]
@@ -41,16 +42,16 @@
 
 [#237]: https://github.com/actix/actix-net/pull/237
 
-
 ## 0.3.0 - 2020-08-23
+
 - No changes from beta 2.
 
-
 ## 0.3.0-beta.2 - 2020-08-19
+
 - Remove unused type parameter from `Framed::replace_codec`.
 
-
 ## 0.3.0-beta.1 - 2020-08-19
+
 - Use `.advance()` instead of `.split_to()`.
 - Upgrade `tokio-util` to `0.3`.
 - Improve `BytesCodec::encode()` performance.
@@ -59,31 +60,31 @@
 - Add method on `Framed` to get a pinned reference to the underlying I/O.
 - Add method on `Framed` check emptiness of read buffer.
 
-
 ## 0.2.0 - 2019-12-10
+
 - Use specific futures dependencies.
 
-
 ## 0.2.0-alpha.4
+
 - Fix buffer remaining capacity calculation.
 
-
 ## 0.2.0-alpha.3
+
 - Use tokio 0.2.
 - Fix low/high watermark for write/read buffers.
 
-
 ## 0.2.0-alpha.2
+
 - Migrated to `std::future`.
 
-
 ## 0.1.2 - 2019-03-27
+
 - Added `Framed::map_io()` method.
 
-
 ## 0.1.1 - 2019-03-06
+
 - Added `FramedParts::with_read_buffer()` method.
 
-
 ## 0.1.0 - 2018-12-09
+
 - Move codec to separate crate.

actix-codec/Cargo.toml

@@ -23,12 +23,12 @@ futures-core = { version = "0.3.7", default-features = false }
 futures-sink = { version = "0.3.7", default-features = false }
 memchr = "2.3"
 pin-project-lite = "0.2"
-tokio = "1.13.1"
+tokio = "1.18.4"
 tokio-util = { version = "0.7", features = ["codec", "io"] }
 tracing = { version = "0.1.30", default-features = false, features = ["log"] }
 
 [dev-dependencies]
-criterion = { version = "0.3", features = ["html_reports"] }
+criterion = { version = "0.4", features = ["html_reports"] }
 tokio-test = "0.4.2"
 
 [[bench]]

actix-codec/src/lib.rs

@@ -1,8 +1,7 @@
 //! Codec utilities for working with framed protocols.
 //!
-//! Contains adapters to go from streams of bytes, [`AsyncRead`] and
-//! [`AsyncWrite`], to framed streams implementing [`Sink`] and [`Stream`].
-//! Framed streams are also known as `transports`.
+//! Contains adapters to go from streams of bytes, [`AsyncRead`] and [`AsyncWrite`], to framed
+//! streams implementing [`Sink`] and [`Stream`]. Framed streams are also known as `transports`.
 //!
 //! [`Sink`]: futures_sink::Sink
 //! [`Stream`]: futures_core::Stream

actix-macros/CHANGES.md

@@ -1,47 +1,48 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 0.2.3 - 2021-10-19
+
 - Fix test macro in presence of other imports named "test". [#399]
 
 [#399]: https://github.com/actix/actix-net/pull/399
 
-
 ## 0.2.2 - 2021-10-14
+
 - Improve error recovery potential when macro input is invalid. [#391]
 - Allow custom `System`s on test macro. [#391]
 
 [#391]: https://github.com/actix/actix-net/pull/391
 
-
 ## 0.2.1 - 2021-02-02
+
 - Add optional argument `system` to `main` macro which can be used to specify the path to `actix_rt::System` (useful for re-exports). [#363]
 
 [#363]: https://github.com/actix/actix-net/pull/363
 
-
 ## 0.2.0 - 2021-02-02
+
 - Update to latest `actix_rt::System::new` signature. [#261]
 
 [#261]: https://github.com/actix/actix-net/pull/261
 
-
 ## 0.2.0-beta.1 - 2021-01-09
+
 - Remove `actix-reexport` feature. [#218]
 
 [#218]: https://github.com/actix/actix-net/pull/218
 
-
 ## 0.1.3 - 2020-12-03
+
 - Add `actix-reexport` feature. [#218]
 
 [#218]: https://github.com/actix/actix-net/pull/218
 
-
 ## 0.1.2 - 2020-05-18
+
 - Forward actix_rt::test arguments to test function [#127]
 
 [#127]: https://github.com/actix/actix-net/pull/127

actix-macros/Cargo.toml

@@ -16,12 +16,12 @@ edition = "2018"
 proc-macro = true
 
 [dependencies]
-quote = "1.0.3"
-syn = { version = "^1", features = ["full"] }
+quote = "1"
+syn = { version = "1", features = ["full"] }
 
 [dev-dependencies]
-actix-rt = "2.0.0"
+actix-rt = "2"
 
-futures-util = { version = "0.3.7", default-features = false }
+futures-util = { version = "0.3.17", default-features = false }
 rustversion = "1"
 trybuild = "1"

actix-macros/tests/trybuild.rs

@@ -1,4 +1,4 @@
-#[rustversion::stable(1.46)] // MSRV
+#[rustversion::stable(1.59)] // MSRV
 #[test]
 fn compile_macros() {
     let t = trybuild::TestCases::new();

actix-rt/CHANGES.md

@@ -1,91 +1,95 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
+
+## 2.8.0 - 2022-12-21
+
 - Add `#[track_caller]` attribute to `spawn` functions and methods. [#454]
-- Minimum supported Rust version (MSRV) is now 1.57.
+- Update `tokio-uring` dependency to `0.4`. [#473]
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 [#454]: https://github.com/actix/actix-net/pull/454
-
+[#473]: https://github.com/actix/actix-net/pull/473
 
 ## 2.7.0 - 2022-03-08
-- Update `tokio-uring` dependency to `0.3.0`. [#448]
+
+- Update `tokio-uring` dependency to `0.3`. [#448]
 - Minimum supported Rust version (MSRV) is now 1.49.
 
 [#448]: https://github.com/actix/actix-net/pull/448
 
-
 ## 2.6.0 - 2022-01-12
-- Update `tokio-uring` dependency to `0.2.0`. [#436]
+
+- Update `tokio-uring` dependency to `0.2`. [#436]
 
 [#436]: https://github.com/actix/actix-net/pull/436
 
-
 ## 2.5.1 - 2021-12-31
+
 - Expose `System::with_tokio_rt` and `Arbiter::with_tokio_rt`. [#430]
 
 [#430]: https://github.com/actix/actix-net/pull/430
 
-
 ## 2.5.0 - 2021-11-22
+
 - Add `System::run_with_code` to allow retrieving the exit code on stop. [#411]
 
 [#411]: https://github.com/actix/actix-net/pull/411
 
-
 ## 2.4.0 - 2021-11-05
+
 - Add `Arbiter::try_current` for situations where thread may or may not have Arbiter context. [#408]
 - Start io-uring with `System::new` when feature is enabled. [#395]
 
 [#395]: https://github.com/actix/actix-net/pull/395
 [#408]: https://github.com/actix/actix-net/pull/408
 
-
 ## 2.3.0 - 2021-10-11
+
 - The `spawn` method can now resolve with non-unit outputs. [#369]
 - Add experimental (semver-exempt) `io-uring` feature for enabling async file I/O on linux. [#374]
 
 [#369]: https://github.com/actix/actix-net/pull/369
 [#374]: https://github.com/actix/actix-net/pull/374
 
-
 ## 2.2.0 - 2021-03-29
-- **BREAKING** `ActixStream::{poll_read_ready, poll_write_ready}` methods now return
-  `Ready` object in ok variant. [#293]
-  * Breakage is acceptable since `ActixStream` was not intended to be public.
+
+- **BREAKING** `ActixStream::{poll_read_ready, poll_write_ready}` methods now return `Ready` object in ok variant. [#293]
+  - Breakage is acceptable since `ActixStream` was not intended to be public.
 
 [#293]: https://github.com/actix/actix-net/pull/293
 
-
 ## 2.1.0 - 2021-02-24
+
 - Add `ActixStream` extension trait to include readiness methods. [#276]
 - Re-export `tokio::net::TcpSocket` in `net` module [#282]
 
 [#276]: https://github.com/actix/actix-net/pull/276
 [#282]: https://github.com/actix/actix-net/pull/282
 
-
 ## 2.0.2 - 2021-02-06
+
 - Add `Arbiter::handle` to get a handle of an owned Arbiter. [#274]
 - Add `System::try_current` for situations where actix may or may not be running a System. [#275]
 
 [#274]: https://github.com/actix/actix-net/pull/274
 [#275]: https://github.com/actix/actix-net/pull/275
 
-
 ## 2.0.1 - 2021-02-06
+
 - Expose `JoinError` from Tokio. [#271]
 
 [#271]: https://github.com/actix/actix-net/pull/271
 
-
 ## 2.0.0 - 2021-02-02
+
 - Remove all Arbiter-local storage methods. [#262]
 - Re-export `tokio::pin`. [#262]
 
 [#262]: https://github.com/actix/actix-net/pull/262
 
-
 ## 2.0.0-beta.3 - 2021-01-31
+
 - Remove `run_in_tokio`, `attach_to_tokio` and `AsyncSystemRunner`. [#253]
 - Return `JoinHandle` from `actix_rt::spawn`. [#253]
 - Remove old `Arbiter::spawn`. Implementation is now inlined into `actix_rt::spawn`. [#253]
@@ -108,21 +112,20 @@
 [#256]: https://github.com/actix/actix-net/pull/256
 [#257]: https://github.com/actix/actix-net/pull/257
 
-
 ## 2.0.0-beta.2 - 2021-01-09
+
 - Add `task` mod with re-export of `tokio::task::{spawn_blocking, yield_now, JoinHandle}` [#245]
 - Add default "macros" feature to allow faster compile times when using `default-features=false`.
 
 [#245]: https://github.com/actix/actix-net/pull/245
 
-
 ## 2.0.0-beta.1 - 2020-12-28
+
 - Add `System::attach_to_tokio` method. [#173]
 - Update `tokio` dependency to `1.0`. [#236]
-- Rename `time` module `delay_for` to `sleep`, `delay_until` to `sleep_until`, `Delay` to `Sleep`
-  to stay aligned with Tokio's naming. [#236]
+- Rename `time` module `delay_for` to `sleep`, `delay_until` to `sleep_until`, `Delay` to `Sleep` to stay aligned with Tokio's naming. [#236]
 - Remove `'static` lifetime requirement for `Runtime::block_on` and `SystemRunner::block_on`.
-  * These methods now accept `&self` when calling. [#236]
+  - These methods now accept `&self` when calling. [#236]
 - Remove `'static` lifetime requirement for `System::run` and `Builder::run`. [#236]
 - `Arbiter::spawn` now panics when `System` is not in scope. [#207]
 - Fix work load issue by removing `PENDING` thread local. [#207]
@@ -130,74 +133,73 @@
 [#207]: https://github.com/actix/actix-net/pull/207
 [#236]: https://github.com/actix/actix-net/pull/236
 
-
 ## 1.1.1 - 2020-04-30
+
 - Fix memory leak due to [#94] (see [#129] for more detail)
 
 [#129]: https://github.com/actix/actix-net/issues/129
 
-
 ## 1.1.0 - 2020-04-08 _(YANKED)_
+
 - Expose `System::is_set` to check if current system has ben started [#99]
 - Add `Arbiter::is_running` to check if event loop is running [#124]
-- Add `Arbiter::local_join` associated function
-  to get be able to `await` for spawned futures [#94]
+- Add `Arbiter::local_join` associated function to get be able to `await` for spawned futures [#94]
 
 [#94]: https://github.com/actix/actix-net/pull/94
 [#99]: https://github.com/actix/actix-net/pull/99
 [#124]: https://github.com/actix/actix-net/pull/124
 
-
 ## 1.0.0 - 2019-12-11
+
 - Update dependencies
 
-
 ## 1.0.0-alpha.3 - 2019-12-07
+
 - Migrate to tokio 0.2
 - Fix compilation on non-unix platforms
 
-
 ## 1.0.0-alpha.2 - 2019-12-02
+
 - Export `main` and `test` attribute macros
 - Export `time` module (re-export of tokio-timer)
 - Export `net` module (re-export of tokio-net)
 
-
 ## 1.0.0-alpha.1 - 2019-11-22
+
 - Migrate to std::future and tokio 0.2
 
-
 ## 0.2.6 - 2019-11-14
+
 - Allow to join arbiter's thread. #60
 - Fix arbiter's thread panic message.
 
-
 ## 0.2.5 - 2019-09-02
+
 - Add arbiter specific storage
 
-
 ## 0.2.4 - 2019-07-17
+
 - Avoid a copy of the Future when initializing the Box. #29
 
-
 ## 0.2.3 - 2019-06-22
+
 - Allow to start System using existing CurrentThread Handle #22
 
-
 ## 0.2.2 - 2019-03-28
+
 - Moved `blocking` module to `actix-threadpool` crate
 
-
 ## 0.2.1 - 2019-03-11
+
 - Added `blocking` module
 - Added `Arbiter::exec_fn` - execute fn on the arbiter's thread
 - Added `Arbiter::exec` - execute fn on the arbiter's thread and wait result
 
-
 ## 0.2.0 - 2019-03-06
+
 - `run` method returns `io::Result<()>`
 - Removed `Handle`
 
-
 ## 0.1.0 - 2018-12-09
+
 - Initial release

actix-rt/Cargo.toml

@@ -1,10 +1,9 @@
 [package]
 name = "actix-rt"
-version = "2.7.0"
+version = "2.8.0"
 authors = [
     "Nikolay Kim <fafhrd91@gmail.com>",
     "Rob Ede <robjtede@icloud.com>",
-    "fakeshadow <24548779@qq.com>",
 ]
 description = "Tokio-based single-threaded async runtime for the Actix ecosystem"
 keywords = ["async", "futures", "io", "runtime"]
@@ -27,12 +26,12 @@ io-uring = ["tokio-uring"]
 actix-macros = { version = "0.2.3", optional = true }
 
 futures-core = { version = "0.3", default-features = false }
-tokio = { version = "1.13.1", features = ["rt", "net", "parking_lot", "signal", "sync", "time"] }
+tokio = { version = "1.18.4", features = ["rt", "net", "parking_lot", "signal", "sync", "time"] }
 
 # runtime for `io-uring` feature
 [target.'cfg(target_os = "linux")'.dependencies]
-tokio-uring = { version = "0.3", optional = true }
+tokio-uring = { version = "0.4", optional = true }
 
 [dev-dependencies]
-tokio = { version = "1.13.1", features = ["full"] }
+tokio = { version = "1.18.4", features = ["full"] }
 hyper = { version = "0.14.10", default-features = false, features = ["server", "tcp", "http1"] }

actix-rt/README.md

@@ -3,11 +3,11 @@
 > Tokio-based single-threaded async runtime for the Actix ecosystem.
 
 [![crates.io](https://img.shields.io/crates/v/actix-rt?label=latest)](https://crates.io/crates/actix-rt)
-[![Documentation](https://docs.rs/actix-rt/badge.svg?version=2.7.0)](https://docs.rs/actix-rt/2.7.0)
+[![Documentation](https://docs.rs/actix-rt/badge.svg?version=2.8.0)](https://docs.rs/actix-rt/2.8.0)
 [![Version](https://img.shields.io/badge/rustc-1.46+-ab6000.svg)](https://blog.rust-lang.org/2020/03/12/Rust-1.46.html)
 ![MIT or Apache 2.0 licensed](https://img.shields.io/crates/l/actix-rt.svg)
 <br />
-[![dependency status](https://deps.rs/crate/actix-rt/2.7.0/status.svg)](https://deps.rs/crate/actix-rt/2.7.0)
+[![dependency status](https://deps.rs/crate/actix-rt/2.8.0/status.svg)](https://deps.rs/crate/actix-rt/2.8.0)
 ![Download](https://img.shields.io/crates/d/actix-rt.svg)
 [![Chat on Discord](https://img.shields.io/discord/771444961383153695?label=chat&logo=discord)](https://discord.gg/WghFtEH6Hb)
 

actix-rt/src/arbiter.rs

@@ -303,7 +303,7 @@ impl Future for ArbiterRunner {
     fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         // process all items currently buffered in channel
         loop {
-            match ready!(Pin::new(&mut self.rx).poll_recv(cx)) {
+            match ready!(self.rx.poll_recv(cx)) {
                 // channel closed; no more messages can be received
                 None => return Poll::Ready(()),
 

actix-rt/src/system.rs

@@ -292,7 +292,7 @@ impl Future for SystemController {
     fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         // process all items currently buffered in channel
         loop {
-            match ready!(Pin::new(&mut self.cmd_rx).poll_recv(cx)) {
+            match ready!(self.cmd_rx.poll_recv(cx)) {
                 // channel closed; no more messages can be received
                 None => return Poll::Ready(()),
 

actix-server/CHANGES.md

@@ -1,63 +1,69 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+## 2.2.0 - 2022-12-21
+
+- Minimum supported Rust version (MSRV) is now 1.59.
+- Update `tokio-uring` dependency to `0.4`. [#473]
+
+[#473]: https://github.com/actix/actix-net/pull/473
 
 ## 2.1.1 - 2022-03-09
+
 - No significant changes since `2.1.0`.
 
-
 ## 2.1.0 - 2022-03-08
-- Update `tokio-uring` dependency to `0.3.0`. [#448]
+
+- Update `tokio-uring` dependency to `0.3`. [#448]
 - Logs emitted now use the `tracing` crate with `log` compatibility. [#448]
 - Wait for accept thread to stop before sending completion signal. [#443]
 
 [#443]: https://github.com/actix/actix-net/pull/443
 [#448]: https://github.com/actix/actix-net/pull/448
 
-
 ## 2.0.0 - 2022-01-19
+
 - No significant changes since `2.0.0-rc.4`.
 
-
 ## 2.0.0-rc.4 - 2022-01-12
-- Update `tokio-uring` dependency to `0.2.0`. [#436]
+
+- Update `tokio-uring` dependency to `0.2`. [#436]
 
 [#436]: https://github.com/actix/actix-net/pull/436
 
-
 ## 2.0.0-rc.3 - 2021-12-31
+
 - No significant changes since `2.0.0-rc.2`.
 
-
 ## 2.0.0-rc.2 - 2021-12-27
+
 - Simplify `TestServer`. [#431]
 
 [#431]: https://github.com/actix/actix-net/pull/431
 
-
 ## 2.0.0-rc.1 - 2021-12-05
+
 - Hide implementation details of `Server`. [#424]
 - `Server` now runs only after awaiting it. [#425]
 
 [#424]: https://github.com/actix/actix-net/pull/424
 [#425]: https://github.com/actix/actix-net/pull/425
 
-
 ## 2.0.0-beta.9 - 2021-11-15
+
 - Restore `Arbiter` support lost in `beta.8`. [#417]
 
 [#417]: https://github.com/actix/actix-net/pull/417
 
-
 ## 2.0.0-beta.8 - 2021-11-05 _(YANKED)_
+
 - Fix non-unix signal handler. [#410]
 
 [#410]: https://github.com/actix/actix-net/pull/410
 
-
 ## 2.0.0-beta.7 - 2021-11-05 _(YANKED)_
+
 - Server can be started in regular Tokio runtime. [#408]
 - Expose new `Server` type whose `Future` impl resolves when server stops. [#408]
 - Rename `Server` to `ServerHandle`. [#407]
@@ -69,34 +75,31 @@
 [#407]: https://github.com/actix/actix-net/pull/407
 [#408]: https://github.com/actix/actix-net/pull/408
 
-
 ## 2.0.0-beta.6 - 2021-10-11
+
 - Add experimental (semver-exempt) `io-uring` feature for enabling async file I/O on linux. [#374]
-- Server no long listens to `SIGHUP` signal. Previously, the received was not used but did block
-  subsequent exit signals from working. [#389]
-- Remove `config` module. `ServiceConfig`, `ServiceRuntime` public types are removed due to
-  this change. [#349]
+- Server no long listens to `SIGHUP` signal. Previously, the received was not used but did block subsequent exit signals from working. [#389]
+- Remove `config` module. `ServiceConfig`, `ServiceRuntime` public types are removed due to this change. [#349]
 - Remove `ServerBuilder::configure` [#349]
 
 [#374]: https://github.com/actix/actix-net/pull/374
 [#349]: https://github.com/actix/actix-net/pull/349
 [#389]: https://github.com/actix/actix-net/pull/389
 
-
 ## 2.0.0-beta.5 - 2021-04-20
-- Server shutdown notifies all workers to exit regardless if shutdown is graceful. This causes all
-  workers to shutdown immediately in force shutdown case. [#333]
+
+- Server shutdown notifies all workers to exit regardless if shutdown is graceful. This causes all workers to shutdown immediately in force shutdown case. [#333]
 
 [#333]: https://github.com/actix/actix-net/pull/333
 
-
 ## 2.0.0-beta.4 - 2021-04-01
+
 - Prevent panic when `shutdown_timeout` is very large. [f9262db]
 
 [f9262db]: https://github.com/actix/actix-net/commit/f9262db
 
-
 ## 2.0.0-beta.3 - 2021-02-06
+
 - Hidden `ServerBuilder::start` method has been removed. Use `ServerBuilder::run`. [#246]
 - Add retry for EINTR signal (`io::Interrupted`) in `Accept`'s poll loop. [#264]
 - Add `ServerBuilder::worker_max_blocking_threads` to customize blocking thread pool size. [#265]
@@ -107,149 +110,148 @@
 [#265]: https://github.com/actix/actix-net/pull/265
 [#273]: https://github.com/actix/actix-net/pull/273
 
-
 ## 2.0.0-beta.2 - 2021-01-03
+
 - Merge `actix-testing` to `actix-server` as `test_server` mod. [#242]
 
 [#242]: https://github.com/actix/actix-net/pull/242
 
-
 ## 2.0.0-beta.1 - 2020-12-28
+
 - Added explicit info log message on accept queue pause. [#215]
 - Prevent double registration of sockets when back-pressure is resolved. [#223]
 - Update `mio` dependency to `0.7.3`. [#239]
 - Remove `socket2` dependency. [#239]
 - `ServerBuilder::backlog` now accepts `u32` instead of `i32`. [#239]
 - Remove `AcceptNotify` type and pass `WakerQueue` to `Worker` to wake up `Accept`'s `Poll`. [#239]
-- Convert `mio::net::TcpStream` to `actix_rt::net::TcpStream`(`UnixStream` for uds) using
-  `FromRawFd` and `IntoRawFd`(`FromRawSocket` and `IntoRawSocket` on windows). [#239]
+- Convert `mio::net::TcpStream` to `actix_rt::net::TcpStream`(`UnixStream` for uds) using `FromRawFd` and `IntoRawFd`(`FromRawSocket` and `IntoRawSocket` on windows). [#239]
 - Remove `AsyncRead` and `AsyncWrite` trait bound for `socket::FromStream` trait. [#239]
 
 [#215]: https://github.com/actix/actix-net/pull/215
 [#223]: https://github.com/actix/actix-net/pull/223
 [#239]: https://github.com/actix/actix-net/pull/239
 
-
 ## 1.0.4 - 2020-09-12
+
 - Update actix-codec to 0.3.0.
 - Workers must be greater than 0. [#167]
 
 [#167]: https://github.com/actix/actix-net/pull/167
 
-
 ## 1.0.3 - 2020-05-19
+
 - Replace deprecated `net2` crate with `socket2` [#140]
 
 [#140]: https://github.com/actix/actix-net/pull/140
 
-
 ## 1.0.2 - 2020-02-26
+
 - Avoid error by calling `reregister()` on Windows [#103]
 
 [#103]: https://github.com/actix/actix-net/pull/103
 
-
 ## 1.0.1 - 2019-12-29
+
 - Rename `.start()` method to `.run()`
 
-
 ## 1.0.0 - 2019-12-11
+
 - Use actix-net releases
 
-
 ## 1.0.0-alpha.4 - 2019-12-08
+
 - Use actix-service 1.0.0-alpha.4
 
-
 ## 1.0.0-alpha.3 - 2019-12-07
+
 - Migrate to tokio 0.2
 - Fix compilation on non-unix platforms
 - Better handling server configuration
 
-
 ## 1.0.0-alpha.2 - 2019-12-02
+
 - Simplify server service (remove actix-server-config)
 - Allow to wait on `Server` until server stops
 
-
 ## 0.8.0-alpha.1 - 2019-11-22
+
 - Migrate to `std::future`
 
-
 ## 0.7.0 - 2019-10-04
+
 - Update `rustls` to 0.16
 - Minimum required Rust version upped to 1.37.0
 
-
 ## 0.6.1 - 2019-09-25
+
 - Add UDS listening support to `ServerBuilder`
 
-
 ## 0.6.0 - 2019-07-18
+
 - Support Unix domain sockets #3
 
-
 ## 0.5.1 - 2019-05-18
+
 - ServerBuilder::shutdown_timeout() accepts u64
 
-
 ## 0.5.0 - 2019-05-12
+
 - Add `Debug` impl for `SslError`
 - Derive debug for `Server` and `ServerCommand`
 - Upgrade to actix-service 0.4
 
-
 ## 0.4.3 - 2019-04-16
+
 - Re-export `IoStream` trait
 - Depend on `ssl` and `rust-tls` features from actix-server-config
 
-
 ## 0.4.2 - 2019-03-30
+
 - Fix SIGINT force shutdown
 
-
 ## 0.4.1 - 2019-03-14
+
 - `SystemRuntime::on_start()` - allow to run future before server service initialization
 
-
 ## 0.4.0 - 2019-03-12
+
 - Use `ServerConfig` for service factory
 - Wrap tcp socket to `Io` type
 - Upgrade actix-service
 
-
 ## 0.3.1 - 2019-03-04
+
 - Add `ServerBuilder::maxconnrate` sets the maximum per-worker number of concurrent connections
 - Add helper ssl error `SslError`
 - Rename `StreamServiceFactory` to `ServiceFactory`
 - Deprecate `StreamServiceFactory`
 
-
 ## 0.3.0 - 2019-03-02
+
 - Use new `NewService` trait
 
-
 ## 0.2.1 - 2019-02-09
+
 - Drop service response
 
-
 ## 0.2.0 - 2019-02-01
+
 - Migrate to actix-service 0.2
 - Updated rustls dependency
 
-
 ## 0.1.3 - 2018-12-21
+
 - Fix max concurrent connections handling
 
-
 ## 0.1.2 - 2018-12-12
+
 - rename ServiceConfig::rt() to ServiceConfig::apply()
 - Fix back-pressure for concurrent ssl handshakes
 
-
 ## 0.1.1 - 2018-12-11
+
 - Fix signal handling on windows
 
-
 ## 0.1.0 - 2018-12-09
+
 - Move server to separate crate

actix-server/Cargo.toml

@@ -1,9 +1,8 @@
 [package]
 name = "actix-server"
-version = "2.1.1"
+version = "2.2.0"
 authors = [
     "Nikolay Kim <fafhrd91@gmail.com>",
-    "fakeshadow <24548779@qq.com>",
     "Rob Ede <robjtede@icloud.com>",
     "Ali MJ Al-Nasrawy <alimjalnasrawy@gmail.com>",
 ]
@@ -24,27 +23,27 @@ default = []
 io-uring = ["tokio-uring", "actix-rt/io-uring"]
 
 [dependencies]
-actix-rt = { version = "2.7", default-features = false }
+actix-rt = { version = "2.8", default-features = false }
 actix-service = "2"
 actix-utils = "3"
 
-futures-core = { version = "0.3.7", default-features = false, features = ["alloc"] }
-futures-util = { version = "0.3.7", default-features = false, features = ["alloc"] }
+futures-core = { version = "0.3.17", default-features = false, features = ["alloc"] }
+futures-util = { version = "0.3.17", default-features = false, features = ["alloc"] }
 mio = { version = "0.8", features = ["os-poll", "net"] }
 num_cpus = "1.13"
 socket2 = "0.4.2"
-tokio = { version = "1.13.1", features = ["sync"] }
+tokio = { version = "1.18.4", features = ["sync"] }
 tracing = { version = "0.1.30", default-features = false, features = ["log"] }
 
 # runtime for `io-uring` feature
 [target.'cfg(target_os = "linux")'.dependencies]
-tokio-uring = { version = "0.3", optional = true }
+tokio-uring = { version = "0.4", optional = true }
 
 [dev-dependencies]
-actix-codec = "0.5.0"
-actix-rt = "2.6.0"
+actix-codec = "0.5"
+actix-rt = "2.8"
 
 bytes = "1"
-env_logger = "0.9"
-futures-util = { version = "0.3.7", default-features = false, features = ["sink", "async-await-macro"] }
-tokio = { version = "1.13.1", features = ["io-util", "rt-multi-thread", "macros", "fs"] }
+env_logger = "0.10"
+futures-util = { version = "0.3.17", default-features = false, features = ["sink", "async-await-macro"] }
+tokio = { version = "1.18.4", features = ["io-util", "rt-multi-thread", "macros", "fs"] }

actix-server/README.md

@@ -3,10 +3,10 @@
 > General purpose TCP server built for the Actix ecosystem.
 
 [![crates.io](https://img.shields.io/crates/v/actix-server?label=latest)](https://crates.io/crates/actix-server)
-[![Documentation](https://docs.rs/actix-server/badge.svg?version=2.1.1)](https://docs.rs/actix-server/2.1.1)
+[![Documentation](https://docs.rs/actix-server/badge.svg?version=2.2.0)](https://docs.rs/actix-server/2.2.0)
 [![Version](https://img.shields.io/badge/rustc-1.52+-ab6000.svg)](https://blog.rust-lang.org/2021/05/06/Rust-1.52.0.html)
 ![License](https://img.shields.io/crates/l/actix-server.svg)
-[![Dependency Status](https://deps.rs/crate/actix-server/2.1.1/status.svg)](https://deps.rs/crate/actix-server/2.1.1)
+[![Dependency Status](https://deps.rs/crate/actix-server/2.2.0/status.svg)](https://deps.rs/crate/actix-server/2.2.0)
 ![Download](https://img.shields.io/crates/d/actix-server.svg)
 [![Chat on Discord](https://img.shields.io/discord/771444961383153695?label=chat&logo=discord)](https://discord.gg/NWpN5mmg3x)
 

actix-server/src/server.rs

@@ -363,6 +363,6 @@ impl Stream for ServerEventMultiplexer {
             }
         }
 
-        Pin::new(&mut this.cmd_rx).poll_recv(cx)
+        this.cmd_rx.poll_recv(cx)
     }
 }

actix-server/src/signals.rs

@@ -96,7 +96,7 @@ impl Future for Signals {
         #[cfg(unix)]
         {
             for (sig, fut) in self.signals.iter_mut() {
-                if Pin::new(fut).poll_recv(cx).is_ready() {
+                if fut.poll_recv(cx).is_ready() {
                     trace!("{} received", sig);
                     return Poll::Ready(*sig);
                 }

actix-server/src/worker.rs

@@ -585,9 +585,7 @@ impl Future for ServerWorker {
         let this = self.as_mut().get_mut();
 
         // `StopWorker` message handler
-        if let Poll::Ready(Some(Stop { graceful, tx })) =
-            Pin::new(&mut this.stop_rx).poll_recv(cx)
-        {
+        if let Poll::Ready(Some(Stop { graceful, tx })) = this.stop_rx.poll_recv(cx) {
             let num = this.counter.total();
             if num == 0 {
                 info!("shutting down idle worker");
@@ -649,7 +647,7 @@ impl Future for ServerWorker {
             }
             WorkerState::Shutdown(ref mut shutdown) => {
                 // drop all pending connections in rx channel.
-                while let Poll::Ready(Some(conn)) = Pin::new(&mut this.conn_rx).poll_recv(cx) {
+                while let Poll::Ready(Some(conn)) = this.conn_rx.poll_recv(cx) {
                     // WorkerCounterGuard is needed as Accept thread has incremented counter.
                     // It's guard's job to decrement the counter together with drop of Conn.
                     let guard = this.counter.guard();
@@ -696,7 +694,7 @@ impl Future for ServerWorker {
                 }
 
                 // handle incoming io stream
-                match ready!(Pin::new(&mut this.conn_rx).poll_recv(cx)) {
+                match ready!(this.conn_rx.poll_recv(cx)) {
                     Some(msg) => {
                         let guard = this.counter.guard();
                         let _ = this.services[msg.token].service.call((guard, msg.io));

actix-service/CHANGES.md

@@ -1,36 +1,37 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 2.0.2 - 2021-12-18
+
 - Service types can now be `Send` and `'static` regardless of request, response, and config types, etc. [#397]
 
 [#397]: https://github.com/actix/actix-net/pull/397
 
-
 ## 2.0.1 - 2021-10-11
+
 - Documentation fix. [#388]
 
 [#388]: https://github.com/actix/actix-net/pull/388
 
-
 ## 2.0.0 - 2021-04-16
+
 - Removed pipeline and related structs/functions. [#335]
 
 [#335]: https://github.com/actix/actix-net/pull/335
 
-
 ## 2.0.0-beta.5 - 2021-03-15
+
 - Add default `Service` trait impl for `Rc<S: Service>` and `&S: Service`. [#288]
 - Add `boxed::rc_service` function for constructing `boxed::RcService` type [#290]
 
 [#288]: https://github.com/actix/actix-net/pull/288
 [#290]: https://github.com/actix/actix-net/pull/290
 
-
 ## 2.0.0-beta.4 - 2021-02-04
+
 - `Service::poll_ready` and `Service::call` receive `&self`. [#247]
 - `apply_fn` and `apply_fn_factory` now receive `Fn(Req, &Service)` function type. [#247]
 - `apply_cfg` and `apply_cfg_factory` now receive `Fn(Req, &Service)` function type. [#247]
@@ -38,158 +39,153 @@
 
 [#247]: https://github.com/actix/actix-net/pull/247
 
-
 ## 2.0.0-beta.3 - 2021-01-09
+
 - The `forward_ready!` macro converts errors. [#246]
 
 [#246]: https://github.com/actix/actix-net/pull/246
 
-
 ## 2.0.0-beta.2 - 2021-01-03
+
 - Remove redundant type parameter from `map_config`.
 
-
 ## 2.0.0-beta.1 - 2020-12-28
-- `Service`, other traits, and many type signatures now take the the request type as a type
-  parameter instead of an associated type. [#232]
+
+- `Service`, other traits, and many type signatures now take the the request type as a type parameter instead of an associated type. [#232]
 - Add `always_ready!` and `forward_ready!` macros. [#233]
 - Crate is now `no_std`. [#233]
 - Migrate pin projections to `pin-project-lite`. [#233]
-- Remove `AndThenApplyFn` and Pipeline `and_then_apply_fn`. Use the
-  `.and_then(apply_fn(...))` construction. [#233]
+- Remove `AndThenApplyFn` and Pipeline `and_then_apply_fn`. Use the `.and_then(apply_fn(...))` construction. [#233]
 - Move non-vital methods to `ServiceExt` and `ServiceFactoryExt` extension traits. [#235]
 
 [#232]: https://github.com/actix/actix-net/pull/232
 [#233]: https://github.com/actix/actix-net/pull/233
 [#235]: https://github.com/actix/actix-net/pull/235
 
-
 ## 1.0.6 - 2020-08-09
-- Removed unsound custom Cell implementation that allowed obtaining several mutable references to
-  the same data, which is undefined behavior in Rust and could lead to violations of memory safety. External code could obtain several mutable references to the same data through
-  service combinators. Attempts to acquire several mutable references to the same data will instead
-  result in a panic.
 
+- Removed unsound custom Cell implementation that allowed obtaining several mutable references to the same data, which is undefined behavior in Rust and could lead to violations of memory safety. External code could obtain several mutable references to the same data through service combinators. Attempts to acquire several mutable references to the same data will instead result in a panic.
 
 ## 1.0.5 - 2020-01-16
+
 - Fixed unsoundness in .and_then()/.then() service combinators.
 
-
 ## 1.0.4 - 2020-01-15
+
 - Revert 1.0.3 change
 
-
 ## 1.0.3 - 2020-01-15
+
 - Fixed unsoundness in `AndThenService` impl.
 
-
 ## 1.0.2 - 2020-01-08
+
 - Add `into_service` helper function.
 
-
 ## 1.0.1 - 2019-12-22
+
 - `map_config()` and `unit_config()` now accept `IntoServiceFactory` type.
 
-
 ## 1.0.0 - 2019-12-11
+
 - Add Clone impl for Apply service
 
-
 ## 1.0.0-alpha.4 - 2019-12-08
+
 - Renamed `service_fn` to `fn_service`
 - Renamed `factory_fn` to `fn_factory`
 - Renamed `factory_fn_cfg` to `fn_factory_with_config`
 
-
 ## 1.0.0-alpha.3 - 2019-12-06
+
 - Add missing Clone impls
 - Restore `Transform::map_init_err()` combinator
 - Restore `Service/Factory::apply_fn()` in form of `Pipeline/Factory::and_then_apply_fn()`
 - Optimize service combinators and futures memory layout
 
-
 ## 1.0.0-alpha.2 - 2019-12-02
+
 - Use owned config value for service factory
 - Renamed BoxedNewService/BoxedService to BoxServiceFactory/BoxService
 
-
 ## 1.0.0-alpha.1 - 2019-11-25
+
 - Migrated to `std::future`
 - `NewService` renamed to `ServiceFactory`
 - Added `pipeline` and `pipeline_factory` function
 
-
 ## 0.4.2 - 2019-08-27
+
 - Check service readiness for `new_apply_cfg` combinator
 
-
 ## 0.4.1 - 2019-06-06
+
 - Add `new_apply_cfg` function
 
-
 ## 0.4.0 - 2019-05-12
+
 - Add `NewService::map_config` and `NewService::unit_config` combinators.
 - Use associated type for `NewService` config.
 - Change `apply_cfg` function.
 - Renamed helper functions.
 
-
 ## 0.3.6 - 2019-04-07
+
 - Poll boxed service call result immediately
 
-
 ## 0.3.5 - 2019-03-29
+
 - Add `impl<S: Service> Service for Rc<RefCell<S>>`.
 
-
 ## 0.3.4 - 2019-03-12
+
 - Add `Transform::from_err()` combinator
 - Add `apply_fn` helper
 - Add `apply_fn_factory` helper
 - Add `apply_transform` helper
 - Add `apply_cfg` helper
 
-
 ## 0.3.3 - 2019-03-09
+
 - Add `ApplyTransform` new service for transform and new service.
 - Add `NewService::apply_cfg()` combinator, allows to use nested `NewService` with different config parameter.
 - Revert IntoFuture change
 
-
 ## 0.3.2 - 2019-03-04
+
 - Change `NewService::Future` and `Transform::Future` to the `IntoFuture` trait.
 - Export `AndThenTransform` type
 
-
 ## 0.3.1 - 2019-03-04
+
 - Simplify Transform trait
 
-
 ## 0.3.0 - 2019-03-02
+
 - Added boxed NewService and Service.
 - Added `Config` parameter to `NewService` trait.
 - Added `Config` parameter to `NewTransform` trait.
 
-
 ## 0.2.2 - 2019-02-19
+
 - Added `NewService` impl for `Rc<S> where S: NewService`
 - Added `NewService` impl for `Arc<S> where S: NewService`
 
-
 ## 0.2.1 - 2019-02-03
+
 - Generalize `.apply` combinator with Transform trait
 
-
 ## 0.2.0 - 2019-02-01
+
 - Use associated type instead of generic for Service definition.
-  * Before:
+  - Before:
     ```rust
     impl Service<Request> for Client {
         type Response = Response;
         // ...
     }
     ```
-  * After:
+  - After:
     ```rust
     impl Service for Client {
         type Request = Request;
@@ -198,31 +194,31 @@
     }
     ```
 
-
 ## 0.1.6 - 2019-01-24
+
 - Use `FnMut` instead of `Fn` for .apply() and .map() combinators and `FnService` type
 - Change `.apply()` error semantic, new service's error is `From<Self::Error>`
 
-
 ## 0.1.5 - 2019-01-13
+
 - Make `Out::Error` convertible from `T::Error` for apply combinator
 
-
 ## 0.1.4 - 2019-01-11
+
 - Use `FnMut` instead of `Fn` for `FnService`
 
-
 ## 0.1.3 - 2018-12-12
+
 - Split service combinators to separate trait
 
-
 ## 0.1.2 - 2018-12-12
+
 - Release future early for `.and_then()` and `.then()` combinators
 
-
 ## 0.1.1 - 2018-12-09
+
 - Added Service impl for `Box<S: Service>`
 
-
 ## 0.1.0 - 2018-12-09
+
 - Initial import

actix-service/Cargo.toml

@@ -4,7 +4,6 @@ version = "2.0.2"
 authors = [
     "Nikolay Kim <fafhrd91@gmail.com>",
     "Rob Ede <robjtede@icloud.com>",
-    "fakeshadow <24548779@qq.com>",
 ]
 description = "Service trait and combinators for representing asynchronous request/response operations."
 keywords = ["network", "framework", "async", "futures", "service"]
@@ -18,11 +17,11 @@ name = "actix_service"
 path = "src/lib.rs"
 
 [dependencies]
-futures-core = { version = "0.3.7", default-features = false }
+futures-core = { version = "0.3.17", default-features = false }
 paste = "1"
 pin-project-lite = "0.2"
 
 [dev-dependencies]
 actix-rt = "2"
 actix-utils = "3"
-futures-util = { version = "0.3.7", default-features = false }
+futures-util = { version = "0.3.17", default-features = false }

actix-tls/CHANGES.md

@@ -1,41 +1,43 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 3.0.4 - 2022-03-15
+
 - Logs emitted now use the `tracing` crate with `log` compatibility. [#451]
 
 [#451]: https://github.com/actix/actix-net/pull/451
 
-
 ## 3.0.3 - 2022-02-15
+
 - No significant changes since `3.0.2`.
 
-
 ## 3.0.2 - 2022-01-28
+
 - Expose `connect::Connection::new`. [#439]
 
 [#439]: https://github.com/actix/actix-net/pull/439
 
-
 ## 3.0.1 - 2022-01-11
+
 - No significant changes since `3.0.0`.
 
-
 ## 3.0.0 - 2021-12-26
+
 - No significant changes since `3.0.0-rc.2`.
 
-
 ## 3.0.0-rc.2 - 2021-12-10
+
 - Re-export `openssl::SslConnectorBuilder` in `connect::openssl::reexports`. [#429]
 
 [#429]: https://github.com/actix/actix-net/pull/429
 
-
 ## 3.0.0-rc.1 - 2021-11-29
+
 ### Added
+
 - Derive `Debug` for `connect::Connection`. [#422]
 - Implement `Display` for `accept::TlsError`. [#422]
 - Implement `Error` for `accept::TlsError` where both types also implement `Error`. [#422]
@@ -45,6 +47,7 @@
 - Implement `Default` for `connect::ConnectorService`. [#423]
 
 ### Changed
+
 - The crate's default features flags no longer include `uri`. [#422]
 - Useful re-exports from underlying TLS crates are exposed in a `reexports` modules in all acceptors and connectors.
 - Convert `connect::ResolverService` from enum to struct. [#422]
@@ -61,6 +64,7 @@
 - Inline modules in `connect::tls` to `connect` module. [#422]
 
 ### Removed
+
 - Remove `connect::{new_connector, new_connector_factory, default_connector, default_connector_factory}` methods. [#422]
 - Remove `connect::native_tls::Connector::service` method. [#422]
 - Remove redundant `connect::Connection::from_parts` method. [#422]
@@ -68,8 +72,8 @@
 [#422]: https://github.com/actix/actix-net/pull/422
 [#423]: https://github.com/actix/actix-net/pull/423
 
-
 ## 3.0.0-beta.9 - 2021-11-22
+
 - Add configurable timeout for accepting TLS connection. [#393]
 - Added `TlsError::Timeout` variant. [#393]
 - All TLS acceptor services now use `TlsError` for their error types. [#393]
@@ -78,31 +82,30 @@
 [#393]: https://github.com/actix/actix-net/pull/393
 [#420]: https://github.com/actix/actix-net/pull/420
 
-
 ## 3.0.0-beta.8 - 2021-11-15
+
 - Add `Connect::request` for getting a reference to the connection request. [#415]
 
 [#415]: https://github.com/actix/actix-net/pull/415
 
-
 ## 3.0.0-beta.7 - 2021-10-20
+
 - Add `webpki_roots_cert_store()` to get rustls compatible webpki roots cert store. [#401]
 - Alias `connect::ssl` to `connect::tls`. [#401]
 
 [#401]: https://github.com/actix/actix-net/pull/401
 
-
 ## 3.0.0-beta.6 - 2021-10-19
+
 - Update `tokio-rustls` to `0.23` which uses `rustls` `0.20`. [#396]
 - Removed a re-export of `Session` from `rustls` as it no longer exist. [#396]
 - Minimum supported Rust version (MSRV) is now 1.52.
 
 [#396]: https://github.com/actix/actix-net/pull/396
 
-
 ## 3.0.0-beta.5 - 2021-03-29
-- Changed `connect::ssl::rustls::RustlsConnectorService` to return error when `DNSNameRef`
-  generation failed instead of panic. [#296]
+
+- Changed `connect::ssl::rustls::RustlsConnectorService` to return error when `DNSNameRef` generation failed instead of panic. [#296]
 - Remove `connect::ssl::openssl::OpensslConnectServiceFactory`. [#297]
 - Remove `connect::ssl::openssl::OpensslConnectService`. [#297]
 - Add `connect::ssl::native_tls` module for native tls support. [#295]
@@ -114,74 +117,72 @@
 [#297]: https://github.com/actix/actix-net/pull/297
 [#299]: https://github.com/actix/actix-net/pull/299
 
-
 ## 3.0.0-beta.4 - 2021-02-24
+
 - Rename `accept::openssl::{SslStream => TlsStream}`.
 - Add `connect::Connect::set_local_addr` to attach local `IpAddr`. [#282]
 - `connector::TcpConnector` service will try to bind to local_addr of `IpAddr` when given. [#282]
 
 [#282]: https://github.com/actix/actix-net/pull/282
 
-
 ## 3.0.0-beta.3 - 2021-02-06
+
 - Remove `trust-dns-proto` and `trust-dns-resolver`. [#248]
 - Use `std::net::ToSocketAddrs` as simple and basic default resolver. [#248]
 - Add `Resolve` trait for custom DNS resolvers. [#248]
 - Add `Resolver::new_custom` function to construct custom resolvers. [#248]
-- Export `webpki_roots::TLS_SERVER_ROOTS` in `actix_tls::connect` mod and remove
-  the export from `actix_tls::accept` [#248]
-- Remove `ConnectTakeAddrsIter`. `Connect::take_addrs` now returns `ConnectAddrsIter<'static>`
-  as owned iterator. [#248]
+- Export `webpki_roots::TLS_SERVER_ROOTS` in `actix_tls::connect` mod and remove the export from `actix_tls::accept` [#248]
+- Remove `ConnectTakeAddrsIter`. `Connect::take_addrs` now returns `ConnectAddrsIter<'static>` as owned iterator. [#248]
 - Rename `Address::{host => hostname}` to more accurately describe which URL segment is returned.
 - Update `actix-rt` to `2.0.0`. [#273]
 
 [#248]: https://github.com/actix/actix-net/pull/248
 [#273]: https://github.com/actix/actix-net/pull/273
 
-
 ## 3.0.0-beta.2 - 2022-xx-xx
+
 - Depend on stable trust-dns packages. [#204]
 
 [#204]: https://github.com/actix/actix-net/pull/204
 
-
 ## 3.0.0-beta.1 - 2020-12-29
+
 - Move acceptors under `accept` module. [#238]
 - Merge `actix-connect` crate under `connect` module. [#238]
 - Add feature flags to enable acceptors and/or connectors individually. [#238]
 
 [#238]: https://github.com/actix/actix-net/pull/238
 
-
 ## 2.0.0 - 2020-09-03
+
 - `nativetls::NativeTlsAcceptor` is renamed to `nativetls::Acceptor`.
 - Where possible, "SSL" terminology is replaced with "TLS".
-    * `SslError` is renamed to `TlsError`.
-    * `TlsError::Ssl` enum variant is renamed to `TlsError::Tls`.
-    * `max_concurrent_ssl_connect` is renamed to `max_concurrent_tls_connect`.
-
+  - `SslError` is renamed to `TlsError`.
+  - `TlsError::Ssl` enum variant is renamed to `TlsError::Tls`.
+  - `max_concurrent_ssl_connect` is renamed to `max_concurrent_tls_connect`.
 
 ## 2.0.0-alpha.2 - 2020-08-17
+
 - Update `rustls` dependency to 0.18
 - Update `tokio-rustls` dependency to 0.14
 - Update `webpki-roots` dependency to 0.20
 
-
 ## [2.0.0-alpha.1] - 2020-03-03
+
 - Update `rustls` dependency to 0.17
 - Update `tokio-rustls` dependency to 0.13
 - Update `webpki-roots` dependency to 0.19
 
-
 ## [1.0.0] - 2019-12-11
+
 - 1.0.0 release
 
-
 ## [1.0.0-alpha.3] - 2019-12-07
+
 - Migrate to tokio 0.2
 - Enable rustls acceptor service
 - Enable native-tls acceptor service
 
-
 ## [1.0.0-alpha.1] - 2019-12-02
+
 - Split openssl acceptor from actix-server package

actix-tls/Cargo.toml

@@ -30,19 +30,18 @@ accept = []
 connect = []
 
 # use openssl impls
-openssl = ["tls-openssl", "tokio-openssl", "actix-codec"]
+openssl = ["tls-openssl", "tokio-openssl"]
 
 # use rustls impls
-rustls = ["tokio-rustls", "webpki-roots", "actix-codec"]
+rustls = ["tokio-rustls", "webpki-roots"]
 
 # use native-tls impls
-native-tls = ["tokio-native-tls", "actix-codec"]
+native-tls = ["tokio-native-tls"]
 
 # support http::Uri as connect address
 uri = ["http"]
 
 [dependencies]
-actix-codec = { version = "0.5.0", optional = true }
 actix-rt = { version = "2.2.0", default-features = false }
 actix-service = "2"
 actix-utils = "3"
@@ -50,6 +49,7 @@ actix-utils = "3"
 futures-core = { version = "0.3.7", default-features = false, features = ["alloc"] }
 impl-more = "0.1"
 pin-project-lite = "0.2.7"
+tokio = "1.18.4"
 tokio-util = "0.7"
 tracing = { version = "0.1.30", default-features = false, features = ["log"] }
 
@@ -68,17 +68,17 @@ webpki-roots = { version = "0.22", optional = true }
 tokio-native-tls = { version = "0.3", optional = true }
 
 [dev-dependencies]
-actix-codec = "0.5.0"
-actix-rt = "2.2.0"
+actix-codec = "0.5"
+actix-rt = "2.2"
 actix-server = "2"
 bytes = "1"
-env_logger = "0.9"
-futures-util = { version = "0.3.7", default-features = false, features = ["sink"] }
+env_logger = "0.10"
+futures-util = { version = "0.3.17", default-features = false, features = ["sink"] }
 log = "0.4"
-rcgen = "0.8"
-rustls-pemfile = "0.2.1"
+rcgen = "0.10"
+rustls-pemfile = "1"
 tokio-rustls = { version = "0.23", features = ["dangerous_configuration"] }
-trust-dns-resolver = "0.20"
+trust-dns-resolver = "0.22"
 
 [[example]]
 name = "accept-rustls"

actix-tls/examples/accept-rustls.rs

@@ -41,8 +41,7 @@ use tracing::info;
 
 #[actix_rt::main]
 async fn main() -> io::Result<()> {
-    env::set_var("RUST_LOG", "info");
-    env_logger::init();
+    env_logger::init_from_env(env_logger::Env::default().default_filter_or("info"));
 
     // Load TLS key and cert files
     let cert_file = &mut BufReader::new(File::open("./examples/cert.pem").unwrap());

actix-tls/src/accept/native_tls.rs

@@ -10,7 +10,6 @@ use std::{
     time::Duration,
 };
 
-use actix_codec::{AsyncRead, AsyncWrite, ReadBuf};
 use actix_rt::{
     net::{ActixStream, Ready},
     time::timeout,
@@ -21,6 +20,7 @@ use actix_utils::{
     future::{ready, Ready as FutReady},
 };
 use futures_core::future::LocalBoxFuture;
+use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
 use tokio_native_tls::{native_tls::Error, TlsAcceptor};
 
 use super::{TlsError, DEFAULT_TLS_HANDSHAKE_TIMEOUT, MAX_CONN_COUNTER};

actix-tls/src/accept/openssl.rs

@@ -11,7 +11,6 @@ use std::{
     time::Duration,
 };
 
-use actix_codec::{AsyncRead, AsyncWrite, ReadBuf};
 use actix_rt::{
     net::{ActixStream, Ready},
     time::{sleep, Sleep},
@@ -23,6 +22,7 @@ use actix_utils::{
 };
 use openssl::ssl::{Error, Ssl, SslAcceptor};
 use pin_project_lite::pin_project;
+use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
 
 use super::{TlsError, DEFAULT_TLS_HANDSHAKE_TIMEOUT, MAX_CONN_COUNTER};
 

actix-tls/src/accept/rustls.rs

@@ -12,7 +12,6 @@ use std::{
     time::Duration,
 };
 
-use actix_codec::{AsyncRead, AsyncWrite, ReadBuf};
 use actix_rt::{
     net::{ActixStream, Ready},
     time::{sleep, Sleep},
@@ -23,6 +22,7 @@ use actix_utils::{
     future::{ready, Ready as FutReady},
 };
 use pin_project_lite::pin_project;
+use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
 use tokio_rustls::rustls::ServerConfig;
 use tokio_rustls::{Accept, TlsAcceptor};
 

actix-tracing/CHANGES.md

@@ -1,8 +1,9 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 0.1.0 - 2020-01-15
+
 - Initial release

actix-utils/CHANGES.md

@@ -2,22 +2,24 @@
 
 ## Unreleased - 2022-xx-xx
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 3.0.1 - 2022-10-21
+
 - Minimum supported Rust version (MSRV) is now 1.57.
 
-
 ## 3.0.0 - 2021-04-16
+
 - No significant changes from `3.0.0-beta.4`.
 
-
 ## 3.0.0-beta.4 - 2021-04-01
+
 - Add `future::Either` type. [#305]
 
 [#305]: https://github.com/actix/actix-net/pull/305
 
-
 ## 3.0.0-beta.3 - 2021-04-01
+
 - Moved `mpsc` to own crate `local-channel`. [#301]
 - Moved `task::LocalWaker` to own crate `local-waker`. [#301]
 - Remove `timeout` module. [#301]
@@ -26,14 +28,14 @@
 
 [#301]: https://github.com/actix/actix-net/pull/301
 
-
 ## 3.0.0-beta.2 - 2021-02-06
+
 - Update `actix-rt` to `2.0.0`. [#273]
 
 [#273]: https://github.com/actix/actix-net/pull/273
 
-
 ## 3.0.0-beta.1 - 2020-12-28
+
 - Update `bytes` dependency to `1`. [#237]
 - Use `pin-project-lite` to replace `pin-project`. [#229]
 - Remove `condition`,`either`,`inflight`,`keepalive`,`oneshot`,`order`,`stream` and `time` mods. [#229]
@@ -41,146 +43,146 @@
 [#229]: https://github.com/actix/actix-net/pull/229
 [#237]: https://github.com/actix/actix-net/pull/237
 
-
 ## 2.0.0 - 2020-08-23
+
 - No changes from beta 1.
 
-
 ## 2.0.0-beta.1 - 2020-08-19
+
 - Upgrade `tokio-util` to `0.3`.
 - Remove unsound custom Cell and use `std::cell::RefCell` instead, as well as `actix-service`.
 - Rename method to correctly spelled `LocalWaker::is_registered`.
 
-
 ## 1.0.6 - 2020-01-08
+
 - Add `Clone` impl for `condition::Waiter`.
 
-
 ## 1.0.5 - 2020-01-08
+
 - Add `Condition` type.
 - Add `Pool` of one-shot's.
 
-
 ## 1.0.4 - 2019-12-20
+
 - Add methods to check `LocalWaker` registration state.
 
-
 ## 1.0.3 - 2019-12-11
+
 - Revert InOrder service changes
 
-
 ## 1.0.2 - 2019-12-11
+
 - Allow to create `framed::Dispatcher` with custom `mpsc::Receiver`.
 - Add `oneshot::Sender::is_canceled()` method.
 
-
 ## 1.0.1 - 2019-12-11
+
 - Optimize InOrder service.
 
-
 ## 1.0.0 - 2019-12-11
+
 - Simplify oneshot and mpsc implementations.
 
-
 ## 1.0.0-alpha.3 - 2019-12-07
+
 - Migrate to tokio 0.2.
 - Fix oneshot.
 
-
 ## 1.0.0-alpha.2 - 2019-12-02
+
 - Migrate to `std::future`.
 
-
 ## 0.4.7 - 2019-10-14
+
 - Re-register task on every framed transport poll.
 
-
 ## 0.4.6 - 2019-10-08
+
 - Refactor `Counter` type. register current task in available method.
 
-
 ## 0.4.5 - 2019-07-19
+
 - Deprecated `CloneableService` as it is not safe.
 
-
 ## 0.4.4 - 2019-07-17
+
 - Undeprecate `FramedTransport` as it is actually useful.
 
-
 ## 0.4.3 - 2019-07-17
+
 - Deprecate `CloneableService` as it is not safe and in general not very useful.
 - Deprecate `FramedTransport` in favor of `actix-ioframe`.
 
-
 ## 0.4.2 - 2019-06-26
+
 - Do not block on sink drop for FramedTransport.
 
-
 ## 0.4.1 - 2019-05-15
+
 - Change `Either` constructor.
 
-
 ## 0.4.0 - 2019-05-11
+
 - Change `Either` to handle two nexted services.
 - Upgrade actix-service 0.4.
 - Removed framed related services.
 - Removed stream related services.
 
-
 ## 0.3.5 - 2019-04-04
+
 - Allow to send messages to `FramedTransport` via mpsc channel.
 - Remove `'static` constraint from Clonable service.
 
-
 ## 0.3.4 - 2019-03-12
+
 - `TimeoutService`, `InOrderService`, `InFlightService` accepts generic IntoService services.
 - Fix `InFlightService::poll_ready()` nested service readiness check.
 - Fix `InOrderService::poll_ready()` nested service readiness check.
 
-
 ## 0.3.3 - 2019-03-09
+
 - Revert IntoFuture change.
 - Add generic config param for IntoFramed and TakeOne new services.
 
-
 ## 0.3.2 - 2019-03-04
+
 - Use IntoFuture for new services.
 
 ## 0.3.1 - 2019-03-04
+
 - Use new type of transform trait.
 
-
 ## 0.3.0 - 2019-03-02
-- Use new `NewService` trait
-- BoxedNewService` and `BoxedService` types moved to actix-service crate.
 
+- Use new `NewService` trait
+- BoxedNewService`and`BoxedService` types moved to actix-service crate.
 
 ## 0.2.4 - 2019-02-21
+
 - Custom `BoxedNewService` implementation.
 
-
 ## 0.2.3 - 2019-02-21
+
 - Add `BoxedNewService` and `BoxedService`.
 
-
 ## 0.2.2 - 2019-02-11
+
 - Add `Display` impl for `TimeoutError`.
 - Add `Display` impl for `InOrderError`.
 
-
 ## 0.2.1 - 2019-02-06
-- Add `InOrder` service. the service yields responses as they become available,
-  in the order that their originating requests were submitted to the service.
+
+- Add `InOrder` service. the service yields responses as they become available, in the order that their originating requests were submitted to the service.
 - Convert `Timeout` and `InFlight` services to a transforms.
 
-
 ## 0.2.0 - 2019-02-01
+
 - Fix framed transport error handling.
 - Added Clone impl for Either service.
 - Added Clone impl for Timeout service factory.
 - Added Service and NewService for Stream dispatcher.
 - Switch to actix-service 0.2.
 
-
 ## 0.1.0 - 2018-12-09
+
 - Move utils services to separate crate.

actix-utils/Cargo.toml

@@ -21,6 +21,6 @@ pin-project-lite = "0.2"
 local-waker = "0.1"
 
 [dev-dependencies]
-actix-rt = "2.0.0"
-futures-util = { version = "0.3.7", default-features = false }
+actix-rt = "2"
+futures-util = { version = "0.3.17", default-features = false }
 static_assertions = "1.1"

bytestring/CHANGES.md

@@ -1,45 +1,61 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
+
+## 1.3.0 - 2023-03-03
+
+- Implement `AsRef<ByteString>` for `ByteString`.
+
+## 1.2.1 - 2022-11-12
+
+- Fix `#[no_std]` compatibility. [#471]
+
+[#471]: https://github.com/actix/actix-net/pull/471
+
+## 1.2.0 - 2022-11-07
+
+- Add `ByteString::slice_ref` which can safely slice a `ByteString` into a new one with zero copy. [#470]
 - Minimum supported Rust version (MSRV) is now 1.57.
 
+[#470]: https://github.com/actix/actix-net/pull/470
 
 ## 1.1.0 - 2022-06-11
+
 - Implement `From<Box<str>>` for `ByteString`. [#458]
 - Implement `Into<String>` for `ByteString`. [#458]
 - Minimum supported Rust version (MSRV) is now 1.49.
 
 [#458]: https://github.com/actix/actix-net/pull/458
 
-
 ## 1.0.0 - 2020-12-31
+
 - Update `bytes` dependency to `1`.
 - Add array and slice of `u8` impls of `TryFrom` up to 32 in length.
 - Rename `get_ref` to `as_bytes` and rename `into_inner` to `into_bytes`.
 - `ByteString::new` is now a `const fn`.
 - Crate is now `#[no_std]` compatible.
 
-
 ## 0.1.5 - 2020-03-30
+
 - Serde support
 
-
 ## 0.1.4 - 2020-01-14
+
 - Fix `AsRef<str>` impl
 
-
 ## 0.1.3 - 2020-01-13
+
 - Add `PartialEq<T: AsRef<str>>`, `AsRef<[u8]>` impls
 
-
 ## 0.1.2 - 2019-12-22
+
 - Fix `new()` method
 - Make `ByteString::from_static()` and `ByteString::from_bytes_unchecked()` methods const.
 
-
 ## 0.1.1 - 2019-12-07
+
 - Fix hash impl
 
-
 ## 0.1.0 - 2019-12-07
+
 - Initial release

bytestring/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bytestring"
-version = "1.1.0"
+version = "1.3.0"
 authors = [
     "Nikolay Kim <fafhrd91@gmail.com>",
     "Rob Ede <robjtede@icloud.com>",
@@ -18,11 +18,11 @@ name = "bytestring"
 path = "src/lib.rs"
 
 [dependencies]
-bytes = "1.2"
+bytes = { version = "1.2", default-features = false }
 serde = { version = "1.0", optional = true }
 
 [dev-dependencies]
-ahash = { version = "0.7.6", default-features = false }
+ahash = { version = "0.8", default-features = false }
 serde_json = "1.0"
 static_assertions = "1.1"
 rustversion = "1"

bytestring/src/lib.rs

@@ -50,6 +50,44 @@ impl ByteString {
     pub const unsafe fn from_bytes_unchecked(src: Bytes) -> ByteString {
         Self(src)
     }
+
+    /// Returns a new byte string that is equivalent to the given `subset`.
+    ///
+    /// When processing a `ByteString` buffer with other tools, one often gets a `&str` which is in
+    /// fact a slice of the original `ByteString`; i.e., a subset of it. This function turns that
+    /// `&str` into another `ByteString`, as if one had sliced the `ByteString` with the offsets
+    /// that correspond to `subset`.
+    ///
+    /// Corresponds to [`Bytes::slice_ref`].
+    ///
+    /// This operation is `O(1)`.
+    ///
+    /// # Panics
+    ///
+    /// Panics if `subset` is not a sub-slice of this byte string.
+    ///
+    /// Note that strings which are only subsets from an equality perspective do not uphold this
+    /// requirement; see examples.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// # use bytestring::ByteString;
+    /// let string = ByteString::from_static(" foo ");
+    /// let subset = string.trim();
+    /// let substring = string.slice_ref(subset);
+    /// assert_eq!(substring, "foo");
+    /// ```
+    ///
+    /// ```should_panic
+    /// # use bytestring::ByteString;
+    /// // panics because the given slice is not derived from the original byte string, despite
+    /// // being a logical subset of the string
+    /// ByteString::from_static("foo bar").slice_ref("foo");
+    /// ```
+    pub fn slice_ref(&self, subset: &str) -> Self {
+        Self(self.0.slice_ref(subset.as_bytes()))
+    }
 }
 
 impl PartialEq<str> for ByteString {
@@ -64,6 +102,12 @@ impl<T: AsRef<str>> PartialEq<T> for ByteString {
     }
 }
 
+impl AsRef<ByteString> for ByteString {
+    fn as_ref(&self) -> &ByteString {
+        self
+    }
+}
+
 impl AsRef<[u8]> for ByteString {
     fn as_ref(&self) -> &[u8] {
         self.0.as_ref()
@@ -249,7 +293,10 @@ mod serde {
 #[cfg(test)]
 mod test {
     use alloc::borrow::ToOwned;
-    use core::hash::{Hash, Hasher};
+    use core::{
+        hash::{Hash, Hasher},
+        panic::{RefUnwindSafe, UnwindSafe},
+    };
 
     use ahash::AHasher;
     use static_assertions::assert_impl_all;
@@ -259,16 +306,7 @@ mod test {
     assert_impl_all!(ByteString: Send, Sync, Unpin, Sized);
     assert_impl_all!(ByteString: Clone, Default, Eq, PartialOrd, Ord);
     assert_impl_all!(ByteString: fmt::Debug, fmt::Display);
-
-    #[rustversion::since(1.56)]
-    mod above_1_56_impls {
-        // `[Ref]UnwindSafe` traits were only in std until rust 1.56
-
-        use core::panic::{RefUnwindSafe, UnwindSafe};
-
-        use super::*;
-        assert_impl_all!(ByteString: UnwindSafe, RefUnwindSafe);
-    }
+    assert_impl_all!(ByteString: UnwindSafe, RefUnwindSafe);
 
     #[test]
     fn test_partial_eq() {
@@ -349,4 +387,21 @@ mod test {
         let s = serde_json::to_string(&ByteString::from_static("nice bytes")).unwrap();
         assert_eq!(s, r#""nice bytes""#);
     }
+
+    #[test]
+    fn slice_ref() {
+        let string = ByteString::from_static(" foo ");
+        let subset = string.trim();
+        // subset is derived from original byte string
+        let substring = string.slice_ref(subset);
+        assert_eq!(substring, "foo");
+    }
+
+    #[test]
+    #[should_panic]
+    fn test_slice_ref_catches_not_a_subset() {
+        // panics because the given slice is not derived from the original byte string, despite
+        // being a logical subset of the string
+        ByteString::from_static("foo bar").slice_ref("foo");
+    }
 }

clippy.toml

@@ -1 +1 @@
-msrv = "1.57"
+msrv = "1.59"

local-channel/CHANGES.md

@@ -1,16 +1,17 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 0.1.3 - 2022-05-03
+
 - Minimum supported Rust version (MSRV) is now 1.49.
 
-
 ## 0.1.2 - 2021-04-01
+
 - No significant changes from `0.1.1`.
 
-
 ## 0.1.1 - 2021-03-29
+
 - Move local mpsc channel to it's own crate.

local-channel/Cargo.toml

@@ -12,10 +12,10 @@ license = "MIT OR Apache-2.0"
 edition = "2018"
 
 [dependencies]
-futures-core = { version = "0.3.7", default-features = false }
-futures-sink = { version = "0.3.7", default-features = false }
-futures-util = { version = "0.3.7", default-features = false }
+futures-core = "0.3.17"
+futures-sink = "0.3.17"
+futures-util = { version = "0.3.17", default-features = false }
 local-waker = "0.1"
 
 [dev-dependencies]
-tokio = { version = "1.13.1", features = ["rt", "macros"] }
+tokio = { version = "1.18.4", features = ["rt", "macros"] }

local-waker/CHANGES.md

@@ -1,16 +1,17 @@
 # Changes
 
 ## Unreleased - 2022-xx-xx
-- Minimum supported Rust version (MSRV) is now 1.57.
 
+- Minimum supported Rust version (MSRV) is now 1.59.
 
 ## 0.1.3 - 2022-05-03
+
 - Minimum supported Rust version (MSRV) is now 1.49.
 
-
 ## 0.1.2 - 2021-12-18
+
 - Fix crate metadata.
 
-
 ## 0.1.1 - 2021-03-29
+
 - Move `LocalWaker` to it's own crate.

local-waker/Cargo.toml

@@ -6,8 +6,8 @@ authors = [
     "Nikolay Kim <fafhrd91@gmail.com>",
     "Rob Ede <robjtede@icloud.com>",
 ]
-keywords = ["waker", "local", "futures", "no-std"]
 repository = "https://github.com/actix/actix-net.git"
+keywords = ["waker", "local", "futures", "no-std"]
 categories = ["asynchronous", "no-std"]
 license = "MIT OR Apache-2.0"
 edition = "2018"