[INFO] fetching crate h3x 0.1.0... [INFO] testing h3x-0.1.0 against master#562dee4820c458d823175268e41601d4c060588a for pr-154210-1 [INFO] extracting crate h3x 0.1.0 into /workspace/builds/worker-3-tc1/source [INFO] started tweaking crates.io crate h3x 0.1.0 [INFO] finished tweaking crates.io crate h3x 0.1.0 [INFO] tweaked toml for crates.io crate h3x 0.1.0 written to /workspace/builds/worker-3-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate h3x 0.1.0 on toolchain 562dee4820c458d823175268e41601d4c060588a [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate h3x 0.1.0 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Updating crates.io index [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded httlib-huffman v0.3.4 [INFO] [stderr] Downloaded matchit v0.9.1 [INFO] [stderr] Downloaded android-build v0.1.3 [INFO] [stderr] Downloaded mac-addr v0.3.0 [INFO] [stderr] Downloaded qmacro v0.4.0 [INFO] [stderr] Downloaded netlink-packet-core v0.8.1 [INFO] [stderr] Downloaded qcongestion v0.4.0 [INFO] [stderr] Downloaded qinterface v0.4.0 [INFO] [stderr] Downloaded bon v3.8.1 [INFO] [stderr] Downloaded bon-macros v3.8.1 [INFO] [stderr] Downloaded x509-parser v0.18.0 [INFO] [stderr] Downloaded qbase v0.4.0 [INFO] [stderr] Downloaded qevent v0.4.0 [INFO] [stderr] Downloaded qrecovery v0.4.0 [INFO] [stderr] Downloaded netlink-packet-route v0.25.1 [INFO] [stderr] Downloaded netdev v0.39.0 [INFO] [stderr] Downloaded qconnection v0.4.0 [INFO] [stderr] Downloaded gm-quic v0.4.0 [INFO] [stderr] Downloaded netwatcher v0.4.0 [INFO] [stderr] Downloaded qudp v0.4.0 [INFO] [stderr] Downloaded zmij v1.0.2 [INFO] [stderr] Downloaded qunreliable v0.4.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 6a147f350d94dd270a7d608d317148400c55206160018d67c721fff73fa522c7 [INFO] running `Command { std: "docker" "start" "-a" "6a147f350d94dd270a7d608d317148400c55206160018d67c721fff73fa522c7", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "6a147f350d94dd270a7d608d317148400c55206160018d67c721fff73fa522c7", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "6a147f350d94dd270a7d608d317148400c55206160018d67c721fff73fa522c7", kill_on_drop: false }` [INFO] [stdout] 6a147f350d94dd270a7d608d317148400c55206160018d67c721fff73fa522c7 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] e69fdab0ef446fcb4280e4ea03634b92326488f20b2010b0b47ec742fe0fd77c [INFO] running `Command { std: "docker" "start" "-a" "e69fdab0ef446fcb4280e4ea03634b92326488f20b2010b0b47ec742fe0fd77c", kill_on_drop: false }` [INFO] [stderr] Compiling libc v0.2.178 [INFO] [stderr] Compiling unicode-segmentation v1.12.0 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling rustls v0.23.35 [INFO] [stderr] Compiling syn v2.0.111 [INFO] [stderr] Compiling proc-macro-error-attr2 v2.0.0 [INFO] [stderr] Compiling memoffset v0.9.1 [INFO] [stderr] Compiling zmij v1.0.2 [INFO] [stderr] Compiling netlink-packet-core v0.8.1 [INFO] [stderr] Compiling rustls-webpki v0.103.8 [INFO] [stderr] Compiling mac-addr v0.3.0 [INFO] [stderr] Compiling nom v8.0.0 [INFO] [stderr] Compiling nom v7.1.3 [INFO] [stderr] Compiling hex v0.4.3 [INFO] [stderr] Compiling time v0.3.44 [INFO] [stderr] Compiling nix v0.30.1 [INFO] [stderr] Compiling nix v0.29.0 [INFO] [stderr] Compiling android-build v0.1.3 [INFO] [stderr] Compiling oid-registry v0.8.1 [INFO] [stderr] Compiling num-bigint v0.4.6 [INFO] [stderr] Compiling data-encoding v2.9.0 [INFO] [stderr] Compiling httlib-huffman v0.3.4 [INFO] [stderr] Compiling convert_case v0.10.0 [INFO] [stderr] Compiling serde_json v1.0.148 [INFO] [stderr] Compiling matchit v0.9.1 [INFO] [stderr] Compiling netwatcher v0.4.0 [INFO] [stderr] Compiling rusticata-macros v4.1.0 [INFO] [stderr] Compiling mio v1.1.1 [INFO] [stderr] Compiling socket2 v0.6.1 [INFO] [stderr] Compiling getrandom v0.3.4 [INFO] [stderr] Compiling netlink-packet-route v0.25.1 [INFO] [stderr] Compiling netlink-sys v0.8.7 [INFO] [stderr] Compiling parking_lot_core v0.9.12 [INFO] [stderr] Compiling getrandom v0.2.16 [INFO] [stderr] Compiling ring v0.17.14 [INFO] [stderr] Compiling rand_core v0.9.3 [INFO] [stderr] Compiling dashmap v6.1.0 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling rand v0.9.2 [INFO] [stderr] Compiling darling_core v0.21.3 [INFO] [stderr] Compiling darling_core v0.20.11 [INFO] [stderr] Compiling darling_core v0.23.0 [INFO] [stderr] Compiling proc-macro-error2 v2.0.1 [INFO] [stderr] Compiling synstructure v0.13.2 [INFO] [stderr] Compiling prettyplease v0.2.37 [INFO] [stderr] Compiling thiserror-impl v2.0.17 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling tokio-macros v2.6.0 [INFO] [stderr] Compiling tracing-attributes v0.1.31 [INFO] [stderr] Compiling derive_more-impl v2.1.1 [INFO] [stderr] Compiling serde_derive v1.0.228 [INFO] [stderr] Compiling enum_dispatch v0.3.13 [INFO] [stderr] Compiling getset v0.1.6 [INFO] [stderr] Compiling asn1-rs-impl v0.2.0 [INFO] [stderr] Compiling displaydoc v0.2.5 [INFO] [stderr] Compiling asn1-rs-derive v0.6.0 [INFO] [stderr] Compiling snafu-derive v0.8.9 [INFO] [stderr] Compiling tokio v1.48.0 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling darling_macro v0.20.11 [INFO] [stderr] Compiling thiserror v2.0.17 [INFO] [stderr] Compiling darling_macro v0.21.3 [INFO] [stderr] Compiling tracing v0.1.44 [INFO] [stderr] Compiling asn1-rs v0.7.1 [INFO] [stderr] Compiling darling_macro v0.23.0 [INFO] [stderr] Compiling darling v0.20.11 [INFO] [stderr] Compiling derive_builder_core v0.20.2 [INFO] [stderr] Compiling darling v0.21.3 [INFO] [stderr] Compiling serde_with_macros v3.16.1 [INFO] [stderr] Compiling bon-macros v3.8.1 [INFO] [stderr] Compiling snafu v0.8.9 [INFO] [stderr] Compiling darling v0.23.0 [INFO] [stderr] Compiling qmacro v0.4.0 [INFO] [stderr] Compiling netdev v0.39.0 [INFO] [stderr] Compiling serde v1.0.228 [INFO] [stderr] Compiling derive_builder_macro v0.20.2 [INFO] [stderr] Compiling derive_more v2.1.1 [INFO] [stderr] Compiling der-parser v10.0.0 [INFO] [stderr] Compiling derive_builder v0.20.2 [INFO] [stderr] Compiling serde_with v3.16.1 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling x509-parser v0.18.0 [INFO] [stderr] Compiling qbase v0.4.0 [INFO] [stderr] Compiling qudp v0.4.0 [INFO] [stderr] Compiling tokio-util v0.7.17 [INFO] [stderr] Compiling bon v3.8.1 [INFO] [stderr] Compiling qevent v0.4.0 [INFO] [stderr] Compiling qunreliable v0.4.0 [INFO] [stderr] Compiling qinterface v0.4.0 [INFO] [stderr] Compiling qrecovery v0.4.0 [INFO] [stderr] Compiling qcongestion v0.4.0 [INFO] [stderr] Compiling qconnection v0.4.0 [INFO] [stderr] Compiling gm-quic v0.4.0 [INFO] [stderr] Compiling h3x v0.1.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 1m 03s [INFO] running `Command { std: "docker" "inspect" "e69fdab0ef446fcb4280e4ea03634b92326488f20b2010b0b47ec742fe0fd77c", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "e69fdab0ef446fcb4280e4ea03634b92326488f20b2010b0b47ec742fe0fd77c", kill_on_drop: false }` [INFO] [stdout] e69fdab0ef446fcb4280e4ea03634b92326488f20b2010b0b47ec742fe0fd77c [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 18920e8ae666e42ecb97184fc88833f64c40999d7c8bbfd50ede2c378d4b14b9 [INFO] running `Command { std: "docker" "start" "-a" "18920e8ae666e42ecb97184fc88833f64c40999d7c8bbfd50ede2c378d4b14b9", kill_on_drop: false }` [INFO] [stderr] Compiling tokio v1.48.0 [INFO] [stderr] Compiling rustls v0.23.35 [INFO] [stderr] Compiling tracing v0.1.44 [INFO] [stderr] Compiling rustls-webpki v0.103.8 [INFO] [stderr] Compiling tracing-subscriber v0.3.22 [INFO] [stderr] Compiling qbase v0.4.0 [INFO] [stderr] Compiling qudp v0.4.0 [INFO] [stderr] Compiling tokio-util v0.7.17 [INFO] [stderr] Compiling qevent v0.4.0 [INFO] [stderr] Compiling qunreliable v0.4.0 [INFO] [stderr] Compiling qrecovery v0.4.0 [INFO] [stderr] Compiling qinterface v0.4.0 [INFO] [stderr] Compiling qcongestion v0.4.0 [INFO] [stderr] Compiling qconnection v0.4.0 [INFO] [stderr] Compiling gm-quic v0.4.0 [INFO] [stderr] Compiling h3x v0.1.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 53.44s [INFO] running `Command { std: "docker" "inspect" "18920e8ae666e42ecb97184fc88833f64c40999d7c8bbfd50ede2c378d4b14b9", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "18920e8ae666e42ecb97184fc88833f64c40999d7c8bbfd50ede2c378d4b14b9", kill_on_drop: false }` [INFO] [stdout] 18920e8ae666e42ecb97184fc88833f64c40999d7c8bbfd50ede2c378d4b14b9 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 4a97d63b03d7fed47bd87e1c39eea761d8e45ebc2a8770bb3dfbff9f5338ba98 [INFO] running `Command { std: "docker" "start" "-a" "4a97d63b03d7fed47bd87e1c39eea761d8e45ebc2a8770bb3dfbff9f5338ba98", kill_on_drop: false }` [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.34s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/h3x-c1056fb88ea22084) [INFO] [stdout] [INFO] [stdout] running 24 tests [INFO] [stdout] test frame::tests::encode_and_decode ... ok [INFO] [stdout] test frame::tests::incomplete_length ... ok [INFO] [stdout] test frame::tests::incomplete_type ... ok [INFO] [stdout] test frame::tests::incomplete_payload ... ok [INFO] [stdout] test frame::tests::new_frame ... ok [INFO] [stdout] test frame::tests::test_data_frames ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_exact_match ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_name_existing ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_no_match ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_value_case_sensitive ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_multiple_entries_same_name ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_empty_value ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_value_empty ... ok [INFO] [stdout] 2026-04-10T08:03:01.963285Z  INFO h3x::qpack::tests: Sent encoder stream type [INFO] [stdout] 2026-04-10T08:03:01.963268Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"mod gm_quic;\n\nuse std::{\n any::Any,\n borrow::Cow,\n convert::Infallible,\n error::Error,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.963384Z  INFO h3x::qpack::tests: Sent decoder stream type [INFO] [stdout] 2026-04-10T08:03:01.963379Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" io,\n ops::DerefMut,\n pin::Pin,\n task::{Context, Poll},\n};\n\nuse bytes::Bytes;\nuse futures" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.963426Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"::{Sink, Stream, future::BoxFuture};\nuse snafu::Snafu;\n\nuse crate::{\n agent::{LocalAgent, RemoteA" stream_id=37 [INFO] [stdout] test qpack::r#static::tests::test_find_name_case_sensitive ... ok2026-04-10T08:03:01.963474Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"gent},\n error::Code,\n varint::VarInt,\n};\n\n#[derive(Debug, Snafu, Clone)]\n#[snafu(visibility(pu" stream_id=37 [INFO] [stdout] [INFO] [stdout] test qpack::r#static::tests::test_find_name_not_existing ... ok2026-04-10T08:03:01.963711Z DEBUG h3x::quic::test: MockStreamWriter send 2 bytes bytes=b"\x014" stream_id=0 [INFO] [stdout] [INFO] [stdout] test qpack::r#static::tests::test_find_value_match_only ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_value_not_existing ... ok [INFO] [stdout] test qpack::r#static::tests::test_static_table_entries ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_name_match_only ... ok [INFO] [stdout] test qpack::r#static::tests::test_static_table_length ... ok [INFO] [stdout] test qpack::r#static::tests::test_find_value_existing ... ok [INFO] [stdout] 2026-04-10T08:03:01.971403Z DEBUG h3x::quic::test: MockStreamWriter send 6 bytes bytes=b"\0\0\xd4\xd7p\x91" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975392Z DEBUG h3x::quic::test: MockStreamWriter send 17 bytes bytes=b"\x9d\x9f+\xc8ZN\xbd\x03\x8dy\x8bU%H\xd7\xa8\xa9" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975441Z DEBUG h3x::quic::test: MockStreamWriter send 2 bytes bytes=b"q\x8a" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975469Z DEBUG h3x::quic::test: MockStreamWriter send 10 bytes bytes=b"`u\x99\x8e\xe1b\xda\xe88\xe4" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975497Z DEBUG h3x::quic::test: MockStreamWriter send 3 bytes bytes=b"\x7fP\x8d" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975515Z DEBUG h3x::quic::test: MockStreamWriter send 13 bytes bytes=b"\x98\xb5\x16\x94\x8db[e\x0c\x01vW\x07" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975561Z  INFO h3x::qpack::tests: Header frame sent [INFO] [stdout] 2026-04-10T08:03:01.975604Z DEBUG h3x::quic::test: MockStreamWriter send 3 bytes bytes=b"\xdd\0\r" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975630Z DEBUG h3x::quic::test: MockStreamWriter send 13 bytes bytes=b"Hello, World!" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975660Z  INFO h3x::qpack::tests: Data frame sent [INFO] [stdout] 2026-04-10T08:03:01.975746Z DEBUG h3x::quic::test: MockStreamReader received 2 bytes bytes=b"\x014" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975805Z DEBUG h3x::quic::test: MockStreamReader received 6 bytes bytes=b"\0\0\xd4\xd7p\x91" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975890Z DEBUG h3x::quic::test: MockStreamReader received 17 bytes bytes=b"\x9d\x9f+\xc8ZN\xbd\x03\x8dy\x8bU%H\xd7\xa8\xa9" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975955Z DEBUG h3x::quic::test: MockStreamReader received 2 bytes bytes=b"q\x8a" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.975988Z DEBUG h3x::quic::test: MockStreamReader received 10 bytes bytes=b"`u\x99\x8e\xe1b\xda\xe88\xe4" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.976028Z DEBUG h3x::quic::test: MockStreamReader received 3 bytes bytes=b"\x7fP\x8d" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.976052Z DEBUG h3x::quic::test: MockStreamReader received 13 bytes bytes=b"\x98\xb5\x16\x94\x8db[e\x0c\x01vW\x07" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.976111Z DEBUG h3x::quic::test: MockStreamReader received 3 bytes bytes=b"\xdd\0\r" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.976231Z  INFO h3x::qpack::tests: Decoded field section field_section=FieldSection { pseudo_headers: Some(Request { method: Some(POST), scheme: Some("https"), authority: Some(h3x.demo.lab.genmeta.net), path: Some(/api/v1/upload) }), header_map: {"user-agent": "genemta-curl/0.3.0", "accept": "*/*"} } [INFO] [stdout] 2026-04-10T08:03:01.976297Z  INFO h3x::qpack::tests: Got data frame, reading [INFO] [stdout] 2026-04-10T08:03:01.976344Z DEBUG h3x::quic::test: MockStreamReader received 13 bytes bytes=b"Hello, World!" stream_id=0 [INFO] [stdout] 2026-04-10T08:03:01.976381Z  INFO h3x::qpack::tests: Read data frame [INFO] [stdout] test qpack::tests::r#static ... ok [INFO] [stdout] 2026-04-10T08:03:01.963623Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"b))]\npub enum StreamError {\n #[snafu(transparent)]\n Connection { source: ConnectionError },\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980415Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" #[snafu(display(\"stream reset with code {code}\"))]\n Reset { code: VarInt },\n}\n\nimpl StreamError" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980476Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" {\n /// Returns `true` if the stream error is [`Reset`].\n ///\n /// [`Reset`]: StreamError::" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980505Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Reset\n #[must_use]\n pub fn is_reset(&self) -> bool {\n matches!(self, Self::Reset { .. }" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980526Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b")\n }\n}\n\nimpl From for io::Error {\n fn from(value: StreamError) -> Self {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980580Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"mod gm_quic;\n\nuse std::{\n any::Any,\n borrow::Cow,\n convert::Infallible,\n error::Error,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980614Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" io,\n ops::DerefMut,\n pin::Pin,\n task::{Context, Poll},\n};\n\nuse bytes::Bytes;\nuse futures" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980637Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"::{Sink, Stream, future::BoxFuture};\nuse snafu::Snafu;\n\nuse crate::{\n agent::{LocalAgent, RemoteA" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980667Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"gent},\n error::Code,\n varint::VarInt,\n};\n\n#[derive(Debug, Snafu, Clone)]\n#[snafu(visibility(pu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980689Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"b))]\npub enum StreamError {\n #[snafu(transparent)]\n Connection { source: ConnectionError },\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980709Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" #[snafu(display(\"stream reset with code {code}\"))]\n Reset { code: VarInt },\n}\n\nimpl StreamError" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980732Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" {\n /// Returns `true` if the stream error is [`Reset`].\n ///\n /// [`Reset`]: StreamError::" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980757Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Reset\n #[must_use]\n pub fn is_reset(&self) -> bool {\n matches!(self, Self::Reset { .. }" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980779Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b")\n }\n}\n\nimpl From for io::Error {\n fn from(value: StreamError) -> Self {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980838Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"match value {\n error @ StreamError::Reset { .. } => io::Error::new(io::ErrorKind::BrokenP" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980866Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ipe, error),\n StreamError::Connection { source } => io::Error::from(source),\n }\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980890Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" }\n}\n\nimpl From for StreamError {\n fn from(value: Infallible) -> Self {\n matc" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980913Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"h value {}\n }\n}\n\nimpl StreamError {\n pub(crate) fn try_from(error: io::Error) -> Result {\n let source = match error.downcast::() {\n Ok(error) => return O" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980957Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"k(error),\n Err(error) => error,\n };\n source.downcast::().m" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.980978Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ap(Self::from)\n }\n}\n\nimpl From for StreamError {\n fn from(error: io::Error) -> Self" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981001Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" {\n match Self::try_from(error) {\n Ok(error) => error,\n Err(error) => {" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981028Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"\n unreachable!(\n \"io::Error({error:?}) cannot be converted to quic" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981074Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"match value {\n error @ StreamError::Reset { .. } => io::Error::new(io::ErrorKind::BrokenP" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981100Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ipe, error),\n StreamError::Connection { source } => io::Error::from(source),\n }\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981122Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" }\n}\n\nimpl From for StreamError {\n fn from(value: Infallible) -> Self {\n matc" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981145Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"h value {}\n }\n}\n\nimpl StreamError {\n pub(crate) fn try_from(error: io::Error) -> Result {\n let source = match error.downcast::() {\n Ok(error) => return O" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981191Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"k(error),\n Err(error) => error,\n };\n source.downcast::().m" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981215Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ap(Self::from)\n }\n}\n\nimpl From for StreamError {\n fn from(error: io::Error) -> Self" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981239Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" {\n match Self::try_from(error) {\n Ok(error) => error,\n Err(error) => {" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981262Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"\n unreachable!(\n \"io::Error({error:?}) cannot be converted to quic" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981303Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"::StreamError, this is a bug\"\n )\n }\n }\n }\n}\n\n#[derive(Debug, Sna" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981356Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"fu, Clone)]\n#[snafu(visibility(pub))]\n#[snafu(display(\"transport error (0x{kind:x} in frame 0x{frame" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981382Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"_type:x}): {reason}\"))]\npub struct TransportError {\n pub kind: VarInt,\n pub frame_type: VarInt" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981406Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b",\n pub reason: Cow<'static, str>,\n}\n\n#[derive(Debug, Snafu, Clone)]\n#[snafu(visibility(pub))]\n#[s" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981430Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"nafu(display(\"application error ({code}): {reason}\"))]\npub struct ApplicationError {\n pub code: C" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981462Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ode,\n pub reason: Cow<'static, str>,\n}\n\n#[derive(Debug, Snafu, Clone)]\n#[snafu(visibility(pub))]\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981486Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"pub enum ConnectionError {\n #[snafu(transparent)]\n Transport { source: TransportError },\n #" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981510Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"[snafu(transparent)]\n Application { source: ApplicationError },\n}\n\nimpl From for" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981533Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" io::Error {\n fn from(value: ConnectionError) -> Self {\n io::Error::new(io::ErrorKind::Bro" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981582Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"::StreamError, this is a bug\"\n )\n }\n }\n }\n}\n\n#[derive(Debug, Sna" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981610Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"fu, Clone)]\n#[snafu(visibility(pub))]\n#[snafu(display(\"transport error (0x{kind:x} in frame 0x{frame" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981634Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"_type:x}): {reason}\"))]\npub struct TransportError {\n pub kind: VarInt,\n pub frame_type: VarInt" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981659Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b",\n pub reason: Cow<'static, str>,\n}\n\n#[derive(Debug, Snafu, Clone)]\n#[snafu(visibility(pub))]\n#[s" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981683Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"nafu(display(\"application error ({code}): {reason}\"))]\npub struct ApplicationError {\n pub code: C" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981707Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ode,\n pub reason: Cow<'static, str>,\n}\n\n#[derive(Debug, Snafu, Clone)]\n#[snafu(visibility(pub))]\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981730Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"pub enum ConnectionError {\n #[snafu(transparent)]\n Transport { source: TransportError },\n #" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981753Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"[snafu(transparent)]\n Application { source: ApplicationError },\n}\n\nimpl From for" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981776Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" io::Error {\n fn from(value: ConnectionError) -> Self {\n io::Error::new(io::ErrorKind::Bro" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981820Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"kenPipe, value)\n }\n}\n\nimpl ConnectionError {\n pub const fn is_transport(&self) -> bool {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981850Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" matches!(self, ConnectionError::Transport { .. })\n }\n\n pub const fn is_application(&self) -" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981874Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"> bool {\n matches!(self, ConnectionError::Application { .. })\n }\n}\n\npub trait Connect {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981899Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" type Connection: Connection;\n type Error: Error + Any;\n\n fn connect(&self, target: &str) -> " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981924Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"BoxFuture<'_, Result>;\n}\n\npub trait Listen {\n type Connection: Con" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981948Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"nection;\n type Error: Error + Any;\n\n fn accept(&self) -> BoxFuture<'_, Result>;\n\n fn shutdown(&self);\n}\n\npub trait Connection:\n ManageStream + WithLocalAgent" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.981996Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" + WithRemoteAgent + Close + Send + Sync + Any\n{\n}\n\nimpl Connection\n for C\n{\n}\n\npub trait ManageStream {\n type Str" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982077Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"kenPipe, value)\n }\n}\n\nimpl ConnectionError {\n pub const fn is_transport(&self) -> bool {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982104Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" matches!(self, ConnectionError::Transport { .. })\n }\n\n pub const fn is_application(&self) -" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982127Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"> bool {\n matches!(self, ConnectionError::Application { .. })\n }\n}\n\npub trait Connect {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982149Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" type Connection: Connection;\n type Error: Error + Any;\n\n fn connect(&self, target: &str) -> " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982173Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"BoxFuture<'_, Result>;\n}\n\npub trait Listen {\n type Connection: Con" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982198Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"nection;\n type Error: Error + Any;\n\n fn accept(&self) -> BoxFuture<'_, Result>;\n\n fn shutdown(&self);\n}\n\npub trait Connection:\n ManageStream + WithLocalAgent" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982256Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" + WithRemoteAgent + Close + Send + Sync + Any\n{\n}\n\nimpl Connection\n for C\n{\n}\n\npub trait ManageStream {\n type Str" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982409Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"eamWriter: WriteStream;\n type StreamReader: ReadStream;\n\n #[allow(clippy::type_complexity)]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982479Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" fn open_bi(\n &self,\n ) -> BoxFuture<'_, Result<(Self::StreamReader, Self::StreamWriter)," stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982526Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" ConnectionError>>;\n\n fn open_uni(&self) -> BoxFuture<'_, Result>;\n\n #[allow(clippy::type_complexity)]\n fn accept_bi(\n &self,\n ) -> BoxFuture<'_" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982635Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b", Result<(Self::StreamReader, Self::StreamWriter), ConnectionError>>;\n\n fn accept_uni(&self) -> B" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.982681Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"oxFuture<'_, Result>;\n}\npub trait WithLocalAgent {\n fn local" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984356Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"_agent(&self) -> BoxFuture<'_, Result, ConnectionError>>;\n}\n\npub trait WithRemote" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984450Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Agent {\n fn remote_agent(&self) -> BoxFuture<'_, Result, ConnectionError>>;\n}" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984501Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"\n\npub trait Close {\n fn close(&self, code: Code, reason: Cow<'static, str>);\n}\n\npub trait GetStre" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984588Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"eamWriter: WriteStream;\n type StreamReader: ReadStream;\n\n #[allow(clippy::type_complexity)]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984650Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" fn open_bi(\n &self,\n ) -> BoxFuture<'_, Result<(Self::StreamReader, Self::StreamWriter)," stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984706Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" ConnectionError>>;\n\n fn open_uni(&self) -> BoxFuture<'_, Result>;\n\n #[allow(clippy::type_complexity)]\n fn accept_bi(\n &self,\n ) -> BoxFuture<'_" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984801Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b", Result<(Self::StreamReader, Self::StreamWriter), ConnectionError>>;\n\n fn accept_uni(&self) -> B" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984862Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"oxFuture<'_, Result>;\n}\npub trait WithLocalAgent {\n fn local" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984917Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"_agent(&self) -> BoxFuture<'_, Result, ConnectionError>>;\n}\n\npub trait WithRemote" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.984962Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Agent {\n fn remote_agent(&self) -> BoxFuture<'_, Result, ConnectionError>>;\n}" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.987358Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"\n\npub trait Close {\n fn close(&self, code: Code, reason: Cow<'static, str>);\n}\n\npub trait GetStre" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.987484Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"amId {\n fn poll_stream_id(self: Pin<&mut Self>, cx: &mut Context) -> Poll>;\n}\n\nimpl

GetStreamId for Pin

\nwhere\n P: DerefMut,\n{\n fn poll_s" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.987699Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"tream_id(self: Pin<&mut Self>, cx: &mut Context) -> Poll> {\n ::poll_stream_id(self.as_deref_mut(), cx)\n }\n}\n\nimpl GetStreamId for &mu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.987811Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"t S\nwhere\n S: GetStreamId + Unpin + ?Sized,\n{\n fn poll_stream_id(self: Pin<&mut Self>, cx: &mu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.987856Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"t Context) -> Poll> {\n S::poll_stream_id(Pin::new(self.get_mut())" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.987926Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b", cx)\n }\n}\n\npin_project_lite::pin_project! {\n pub struct StreamId{\n #[pin]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.987977Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" stream: S\n }\n}\n\nimpl Future for StreamId {\n type Output = R" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.988043Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"esult;\n\n fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll, cx: &mut Context) -> Poll>;\n}\n\nimpl

GetStreamId for Pin

\nwhere\n P: DerefMut,\n{\n fn poll_s" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996484Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"tream_id(self: Pin<&mut Self>, cx: &mut Context) -> Poll> {\n ::poll_stream_id(self.as_deref_mut(), cx)\n }\n}\n\nimpl GetStreamId for &mu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996541Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"t S\nwhere\n S: GetStreamId + Unpin + ?Sized,\n{\n fn poll_stream_id(self: Pin<&mut Self>, cx: &mu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996566Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"t Context) -> Poll> {\n S::poll_stream_id(Pin::new(self.get_mut())" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996591Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b", cx)\n }\n}\n\npin_project_lite::pin_project! {\n pub struct StreamId{\n #[pin]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996618Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" stream: S\n }\n}\n\nimpl Future for StreamId {\n type Output = R" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996643Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"esult;\n\n fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll {\n let project = self.project();\n project.stream.poll_stream_id(cx)\n }\n}\n\npu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996759Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"b trait GetStreamIdExt {\n fn stream_id(&mut self) -> StreamId<&mut Self> {\n StreamId { str" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996787Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"eam: self }\n }\n}\n\nimpl GetStreamIdExt for T {}\n\npub trait StopStream {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996815Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" fn poll_stop(\n self: Pin<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n )" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996841Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" -> Poll>;\n}\n\nimpl

StopStream for Pin

\nwhere\n P: DerefMut,\n{\n fn poll_stop(\n self: Pin<&mut Self>,\n cx: &mut Context,\n code:" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996900Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" VarInt,\n ) -> Poll> {\n ::poll_stop(self." stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996927Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"as_deref_mut(), cx, code)\n }\n}\n\nimpl StopStream for &mut S\nwhere\n S: StopStream + Unpin + ?" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.996953Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Sized,\n{\n fn poll_stop(\n self: Pin<&mut Self>,\n cx: &mut Context,\n code: Var" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997010Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"utput> {\n let project = self.project();\n project.stream.poll_stream_id(cx)\n }\n}\n\npu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997041Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"b trait GetStreamIdExt {\n fn stream_id(&mut self) -> StreamId<&mut Self> {\n StreamId { str" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997067Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"eam: self }\n }\n}\n\nimpl GetStreamIdExt for T {}\n\npub trait StopStream {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997095Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" fn poll_stop(\n self: Pin<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n )" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997121Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" -> Poll>;\n}\n\nimpl

StopStream for Pin

\nwhere\n P: DerefMut,\n{\n fn poll_stop(\n self: Pin<&mut Self>,\n cx: &mut Context,\n code:" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997172Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" VarInt,\n ) -> Poll> {\n ::poll_stop(self." stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997201Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"as_deref_mut(), cx, code)\n }\n}\n\nimpl StopStream for &mut S\nwhere\n S: StopStream + Unpin + ?" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997230Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Sized,\n{\n fn poll_stop(\n self: Pin<&mut Self>,\n cx: &mut Context,\n code: Var" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997279Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Int,\n ) -> Poll> {\n S::poll_stop(Pin::new(self.get_mut()), cx, cod" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997336Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"e)\n }\n}\n\npin_project_lite::pin_project! {\n pub struct Stop{\n code: VarInt,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997366Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" #[pin]\n stream: S\n }\n}\n\nimpl Future for Stop {\n type " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997390Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Output = Result<(), StreamError>;\n\n fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll {\n let project = self.project();\n project.stream.poll_stop(cx, *project.c" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997433Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ode)\n }\n}\n\npub trait StopStreamExt {\n fn stop(&mut self, code: VarInt) -> Stop<&mut Self> {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997466Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" Stop { code, stream: self }\n }\n}\n\nimpl StopStreamExt for T {}\n\npub " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997489Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"trait ReadStream:\n StopStream + GetStreamId + Stream> + Send + " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997512Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Any\n{\n}\n\nimpl> + Send + ?Size" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997562Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Int,\n ) -> Poll> {\n S::poll_stop(Pin::new(self.get_mut()), cx, cod" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997590Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"e)\n }\n}\n\npin_project_lite::pin_project! {\n pub struct Stop{\n code: VarInt,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997624Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" #[pin]\n stream: S\n }\n}\n\nimpl Future for Stop {\n type " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997650Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Output = Result<(), StreamError>;\n\n fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll {\n let project = self.project();\n project.stream.poll_stop(cx, *project.c" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997697Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ode)\n }\n}\n\npub trait StopStreamExt {\n fn stop(&mut self, code: VarInt) -> Stop<&mut Self> {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997720Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" Stop { code, stream: self }\n }\n}\n\nimpl StopStreamExt for T {}\n\npub " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997746Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"trait ReadStream:\n StopStream + GetStreamId + Stream> + Send + " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997770Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Any\n{\n}\n\nimpl> + Send + ?Size" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997810Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"d + Any>\n ReadStream for S\n{\n}\n\npub trait CancelStream {\n fn poll_cancel(\n self: Pin<&m" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997842Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll>;\n}\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997868Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"\nimpl CancelStream for &mut S\nwhere\n S: CancelStream + Unpin + ?Sized,\n{\n fn poll_cancel(\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997892Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" self: Pin<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll> {\n S::poll_cancel(Pin::new(self.get_mut()), cx, code)\n }\n}\n\nimpl

Cancel" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997940Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Stream for Pin

\nwhere\n P: DerefMut,\n{\n fn poll_cancel(\n self: P" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997964Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"in<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.997988Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"> {\n ::poll_cancel(self.as_deref_mut(), cx, code)\n }\n}\n\npin_pro" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998011Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ject_lite::pin_project! {\n pub struct Cancel{\n code: VarInt,\n #[pin]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998055Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"d + Any>\n ReadStream for S\n{\n}\n\npub trait CancelStream {\n fn poll_cancel(\n self: Pin<&m" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998080Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll>;\n}\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998103Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"\nimpl CancelStream for &mut S\nwhere\n S: CancelStream + Unpin + ?Sized,\n{\n fn poll_cancel(\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998130Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" self: Pin<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll> {\n S::poll_cancel(Pin::new(self.get_mut()), cx, code)\n }\n}\n\nimpl

Cancel" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998177Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Stream for Pin

\nwhere\n P: DerefMut,\n{\n fn poll_cancel(\n self: P" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998202Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"in<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998227Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"> {\n ::poll_cancel(self.as_deref_mut(), cx, code)\n }\n}\n\npin_pro" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998251Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ject_lite::pin_project! {\n pub struct Cancel{\n code: VarInt,\n #[pin]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998292Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" stream: S\n }\n}\n\nimpl Future for Cancel {\n type Output = Resul" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998344Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"t<(), StreamError>;\n\n fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll {" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998369Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"\n let project = self.project();\n project.stream.poll_cancel(cx, *project.code)\n }\n}" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998391Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"\n\npub trait CancelStreamExt {\n fn cancel(&mut self, code: VarInt) -> Cancel<&mut Self> {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998412Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Cancel { code, stream: self }\n }\n}\n\nimpl CancelStreamExt for T {}\n\npub " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998434Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"trait WriteStream:\n CancelStream + GetStreamId + Sink + Send + Any\n{\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998466Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"}\n\nimpl + Send + ?Sized + Any>\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998490Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"WriteStream for S\n{\n}\n\n#[cfg(test)]\npub mod test {\n use std::{\n pin::Pin,\n task::{C" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998515Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ontext, Poll, ready},\n };\n\n use bytes::Bytes;\n use futures::{Sink, SinkExt, Stream, StreamE" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998563Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" stream: S\n }\n}\n\nimpl Future for Cancel {\n type Output = Resul" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998590Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"t<(), StreamError>;\n\n fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll {" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998614Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"\n let project = self.project();\n project.stream.poll_cancel(cx, *project.code)\n }\n}" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998637Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"\n\npub trait CancelStreamExt {\n fn cancel(&mut self, code: VarInt) -> Cancel<&mut Self> {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998662Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Cancel { code, stream: self }\n }\n}\n\nimpl CancelStreamExt for T {}\n\npub " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998685Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"trait WriteStream:\n CancelStream + GetStreamId + Sink + Send + Any\n{\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998708Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"}\n\nimpl + Send + ?Sized + Any>\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998731Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"WriteStream for S\n{\n}\n\n#[cfg(test)]\npub mod test {\n use std::{\n pin::Pin,\n task::{C" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998755Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ontext, Poll, ready},\n };\n\n use bytes::Bytes;\n use futures::{Sink, SinkExt, Stream, StreamE" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998795Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"xt};\n use tokio::sync::oneshot;\n\n use crate::{\n quic::{CancelStream, GetStreamId, StopS" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998826Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"tream, StreamError},\n varint::VarInt,\n };\n\n pin_project_lite::pin_project! {\n pu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998849Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"b struct MockStreamWriter {\n stream_id: VarInt,\n #[pin]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998872Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" stop_sending: oneshot::Receiver,\n #[pin]\n stream: S,\n }\n\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998899Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" impl PinnedDrop for MockStreamWriter {\n fn drop(this: Pin<&mut Self>) {\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998923Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" println!(\"Dropping MockStreamWriter({})\", this.stream_id);\n }\n }\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998948Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" }\n\n pub enum Packet {\n Stream(Bytes),\n Reset(VarInt),\n }\n\n impl" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998972Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" GetStreamId for MockStreamWriter {\n fn poll_stream_id(\n self: Pin<&mut Self>,\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.998995Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" _cx: &mut Context,\n ) -> Poll> {\n Ok(self." stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999041Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"xt};\n use tokio::sync::oneshot;\n\n use crate::{\n quic::{CancelStream, GetStreamId, StopS" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999069Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"tream, StreamError},\n varint::VarInt,\n };\n\n pin_project_lite::pin_project! {\n pu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999095Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"b struct MockStreamWriter {\n stream_id: VarInt,\n #[pin]\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999120Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" stop_sending: oneshot::Receiver,\n #[pin]\n stream: S,\n }\n\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999146Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" impl PinnedDrop for MockStreamWriter {\n fn drop(this: Pin<&mut Self>) {\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999171Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" println!(\"Dropping MockStreamWriter({})\", this.stream_id);\n }\n }\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999198Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" }\n\n pub enum Packet {\n Stream(Bytes),\n Reset(VarInt),\n }\n\n impl" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999224Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" GetStreamId for MockStreamWriter {\n fn poll_stream_id(\n self: Pin<&mut Self>,\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999250Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" _cx: &mut Context,\n ) -> Poll> {\n Ok(self." stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999293Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"stream_id).into()\n }\n }\n\n impl + ?Sized> CancelStream for MockStreamWri" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999346Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ter\n where\n StreamError: From,\n {\n fn poll_cancel(\n self" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999369Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b": Pin<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll> {\n let mut project = self.project();\n ready!(project.stream.a" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999410Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"s_mut().poll_ready(cx)?);\n project.stream.as_mut().start_send(Packet::Reset(code))?;\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999432Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" Poll::Ready(Ok(()))\n }\n }\n\n impl + ?Sized> Sink for Mock" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999464Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"StreamWriter\n where\n StreamError: From,\n {\n type Error = StreamErro" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999487Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"r;\n\n fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n self.project().stream.poll_ready(cx).map_err(From::from)\n }\n\n fn star" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999553Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"stream_id).into()\n }\n }\n\n impl + ?Sized> CancelStream for MockStreamWri" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999578Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ter\n where\n StreamError: From,\n {\n fn poll_cancel(\n self" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999599Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b": Pin<&mut Self>,\n cx: &mut Context,\n code: VarInt,\n ) -> Poll> {\n let mut project = self.project();\n ready!(project.stream.a" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999642Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"s_mut().poll_ready(cx)?);\n project.stream.as_mut().start_send(Packet::Reset(code))?;\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999666Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" Poll::Ready(Ok(()))\n }\n }\n\n impl + ?Sized> Sink for Mock" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999689Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"StreamWriter\n where\n StreamError: From,\n {\n type Error = StreamErro" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999712Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"r;\n\n fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n self.project().stream.poll_ready(cx).map_err(From::from)\n }\n\n fn star" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999772Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"t_send(self: Pin<&mut Self>, bytes: Bytes) -> Result<(), Self::Error> {\n tracing::debug!(" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999802Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"\n ?bytes,\n stream_id = self.stream_id.into_inner(),\n \"M" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999825Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ockStreamWriter send {} bytes\",\n bytes.len()\n );\n self.project(" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999848Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b")\n .stream\n .start_send(Packet::Stream(bytes))\n .map_er" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999872Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"r(From::from)\n }\n\n fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n self.project().stream.poll_flush(cx).map_err(From::from)\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999922Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" }\n\n fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n self.project().stream.poll_close(cx).map_err(From::from)\n }\n }\n\n enu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:01.999969Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"m ReceiverResetState {\n None,\n ResetReceived(VarInt),\n }\n\n pin_project_lite::pin" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000012Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"t_send(self: Pin<&mut Self>, bytes: Bytes) -> Result<(), Self::Error> {\n tracing::debug!(" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000042Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"\n ?bytes,\n stream_id = self.stream_id.into_inner(),\n \"M" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000067Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ockStreamWriter send {} bytes\",\n bytes.len()\n );\n self.project(" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000091Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b")\n .stream\n .start_send(Packet::Stream(bytes))\n .map_er" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000116Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"r(From::from)\n }\n\n fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n self.project().stream.poll_flush(cx).map_err(From::from)\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000161Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" }\n\n fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n self.project().stream.poll_close(cx).map_err(From::from)\n }\n }\n\n enu" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000209Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"m ReceiverResetState {\n None,\n ResetReceived(VarInt),\n }\n\n pin_project_lite::pin" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000248Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"_project! {\n pub struct MockStreamReader {\n stream_id: VarInt,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.000279Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" stop_sending_tx: Option>,\n reset: ReceiverResetState,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.002156Z  INFO test: Listening on [::1]:60208 [INFO] [stdout] 2026-04-10T08:03:02.005484Z DEBUG rustls::webpki::anchors: add_parsable_certificates processed 1 valid and 0 invalid certs [INFO] [stdout] 2026-04-10T08:03:02.005655Z DEBUG rustls::webpki::anchors: add_parsable_certificates processed 1 valid and 0 invalid certs [INFO] [stdout] 2026-04-10T08:03:02.006231Z DEBUG client_fallback:execute_request: h3x::pool: (Re)trying to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.000303Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" #[pin]\n stream: S,\n }\n\n impl PinnedDrop for MockStreamReade" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.006369Z DEBUG client_fallback:execute_request: h3x::pool: Acquired connection lock, try to initial connection [INFO] [stdout] 2026-04-10T08:03:02.006405Z DEBUG client_fallback:execute_request: h3x::pool: Trying to connect to localhost:60208 [INFO] [stdout] 2026-04-10T08:03:02.006432Z DEBUG client_fallback:execute_request: h3x::client: Connecting to localhost:60208 via gm_quic [INFO] [stdout] 2026-04-10T08:03:02.006466Z DEBUG client_fallback:execute_request: gm_quic::client: Connecting to localhost:60208 [INFO] [stdout] 2026-04-10T08:03:02.006477Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"r {\n fn drop(this: Pin<&mut Self>) {\n println!(\"Dropping MockStreamRead" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.006572Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"er({})\", this.stream_id);\n }\n }\n }\n\n impl GetStreamId for MockStr" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.006621Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"eamReader {\n fn poll_stream_id(\n self: Pin<&mut Self>,\n _cx: &mut Co" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.006662Z DEBUG client_echo:execute_request: h3x::pool: (Re)trying to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.006692Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ntext,\n ) -> Poll> {\n Poll::Ready(Ok(self.stream_id))\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.006752Z DEBUG client_health:execute_request: h3x::pool: (Re)trying to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.006765Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" }\n }\n\n impl StopStream for MockStreamReader {\n fn poll_stop(\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.006844Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" self: Pin<&mut Self>,\n _cx: &mut Context,\n code: VarInt,\n ) -> " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.006944Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"_project! {\n pub struct MockStreamReader {\n stream_id: VarInt,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007016Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" stop_sending_tx: Option>,\n reset: ReceiverResetState,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007065Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" #[pin]\n stream: S,\n }\n\n impl PinnedDrop for MockStreamReade" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007123Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"r {\n fn drop(this: Pin<&mut Self>) {\n println!(\"Dropping MockStreamRead" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007176Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"er({})\", this.stream_id);\n }\n }\n }\n\n impl GetStreamId for MockStr" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007233Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"eamReader {\n fn poll_stream_id(\n self: Pin<&mut Self>,\n _cx: &mut Co" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007276Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ntext,\n ) -> Poll> {\n Poll::Ready(Ok(self.stream_id))\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007329Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" }\n }\n\n impl StopStream for MockStreamReader {\n fn poll_stop(\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007395Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" self: Pin<&mut Self>,\n _cx: &mut Context,\n code: VarInt,\n ) -> " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.007473Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"Poll> {\n let project = self.project();\n if let Some(tx" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009363Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b") = project.stop_sending_tx.take() {\n let _ = tx.send(code);\n }\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009458Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" Poll::Ready(Ok(()))\n }\n }\n\n impl> + ?Siz" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009507Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ed> Stream for MockStreamReader {\n type Item = Result;\n\n fn pol" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009565Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"l_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n let mut" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009608Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" project = self.project();\n loop {\n if let ReceiverResetState::ResetReceiv" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009651Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ed(code) = *project.reset {\n return Poll::Ready(Some(Err(StreamError::Reset { cod" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009713Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"e })));\n }\n match ready!(project.stream.as_mut().poll_next(cx)?) {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009764Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" Some(Packet::Stream(bytes)) => {\n tracing::debug!(\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009852Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"Poll> {\n let project = self.project();\n if let Some(tx" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.009947Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b") = project.stop_sending_tx.take() {\n let _ = tx.send(code);\n }\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010004Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" Poll::Ready(Ok(()))\n }\n }\n\n impl> + ?Siz" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010057Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ed> Stream for MockStreamReader {\n type Item = Result;\n\n fn pol" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010115Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"l_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> {\n let mut" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010160Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" project = self.project();\n loop {\n if let ReceiverResetState::ResetReceiv" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010202Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ed(code) = *project.reset {\n return Poll::Ready(Some(Err(StreamError::Reset { cod" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010264Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"e })));\n }\n match ready!(project.stream.as_mut().poll_next(cx)?) {\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010328Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" Some(Packet::Stream(bytes)) => {\n tracing::debug!(\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010408Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" ?bytes,\n stream_id = project.stream_id.into_inner(),\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010472Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" \"MockStreamReader received {} bytes\",\n bytes.l" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010533Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"en()\n );\n return Poll::Ready(Some(Ok(bytes)));\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010577Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" }\n Some(Packet::Reset(code)) => {\n *project.r" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010623Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"eset = ReceiverResetState::ResetReceived(code);\n }\n None => re" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010665Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"turn Poll::Ready(None),\n }\n }\n }\n }\n\n pub fn mock_stream_pair" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010710Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"(\n stream_id: VarInt,\n ) -> (\n MockStreamReader>>,\n MockStreamWriter>,\n ) {\n let" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010814Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" (stop_sending_tx, stop_sending_rx) = oneshot::channel();\n let (packet_tx, packet_rx) = futur" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010887Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" ?bytes,\n stream_id = project.stream_id.into_inner(),\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.010955Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" \"MockStreamReader received {} bytes\",\n bytes.l" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.011000Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"en()\n );\n return Poll::Ready(Some(Ok(bytes)));\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.011053Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" }\n Some(Packet::Reset(code)) => {\n *project.r" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.011097Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"eset = ReceiverResetState::ResetReceived(code);\n }\n None => re" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.011150Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"turn Poll::Ready(None),\n }\n }\n }\n }\n\n pub fn mock_stream_pair" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.011197Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"(\n stream_id: VarInt,\n ) -> (\n MockStreamReader>>,\n MockStreamWriter>,\n ) {\n let" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.011293Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" (stop_sending_tx, stop_sending_rx) = oneshot::channel();\n let (packet_tx, packet_rx) = futur" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.011384Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"es::channel::mpsc::channel(8);\n\n let writer = MockStreamWriter {\n stream_id,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013363Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" stop_sending: stop_sending_rx,\n stream: packet_tx.sink_map_err(|_| StreamError::Re" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013464Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"set {\n code: VarInt::from_u32(0),\n }),\n };\n\n let reader = Mo" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013513Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"ckStreamReader {\n stream_id,\n stop_sending_tx: Some(stop_sending_tx),\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013573Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" reset: ReceiverResetState::None,\n stream: packet_rx.map(Ok),\n };\n\n (rea" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013623Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"der, writer)\n }\n\n #[tokio::test]\n async fn pair() {\n let (mut reader, mut writer) = " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013683Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"mock_stream_pair(VarInt::from_u32(37));\n\n let file = include_bytes!(\"./quic.rs\");\n let" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013737Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b" send = async {\n for part in file.chunks(100) {\n writer.feed(Bytes::copy_f" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013799Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"rom_slice(part)).await.unwrap();\n }\n writer.close().await.unwrap();\n };" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013876Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"es::channel::mpsc::channel(8);\n\n let writer = MockStreamWriter {\n stream_id,\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013943Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" stop_sending: stop_sending_rx,\n stream: packet_tx.sink_map_err(|_| StreamError::Re" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.013989Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"set {\n code: VarInt::from_u32(0),\n }),\n };\n\n let reader = Mo" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014052Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"ckStreamReader {\n stream_id,\n stop_sending_tx: Some(stop_sending_tx),\n " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014104Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" reset: ReceiverResetState::None,\n stream: packet_rx.map(Ok),\n };\n\n (rea" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014158Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"der, writer)\n }\n\n #[tokio::test]\n async fn pair() {\n let (mut reader, mut writer) = " stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014219Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"mock_stream_pair(VarInt::from_u32(37));\n\n let file = include_bytes!(\"./quic.rs\");\n let" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014277Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b" send = async {\n for part in file.chunks(100) {\n writer.feed(Bytes::copy_f" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014347Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"rom_slice(part)).await.unwrap();\n }\n writer.close().await.unwrap();\n };" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014426Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"\n let recv = async {\n let mut received = Vec::new();\n while let Some(ch" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014501Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"unk) = reader.next().await {\n let chunk = chunk.unwrap();\n received.ex" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014569Z DEBUG h3x::quic::test: MockStreamWriter send 100 bytes bytes=b"tend_from_slice(&chunk);\n }\n assert!(received == file);\n };\n tok" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014631Z DEBUG h3x::quic::test: MockStreamWriter send 31 bytes bytes=b"io::join!(send, recv);\n }\n}\n" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014712Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"\n let recv = async {\n let mut received = Vec::new();\n while let Some(ch" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.014761Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"unk) = reader.next().await {\n let chunk = chunk.unwrap();\n received.ex" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.016356Z DEBUG h3x::quic::test: MockStreamReader received 100 bytes bytes=b"tend_from_slice(&chunk);\n }\n assert!(received == file);\n };\n tok" stream_id=37 [INFO] [stdout] 2026-04-10T08:03:02.016441Z DEBUG h3x::quic::test: MockStreamReader received 31 bytes bytes=b"io::join!(send, recv);\n }\n}\n" stream_id=37 [INFO] [stdout] test quic::test::pair ... ok [INFO] [stdout] 2026-04-10T08:03:02.147506Z DEBUG client_fallback:execute_request: h3x::client: DNS lookup for localhost:60208 returned about 2 addresses [INFO] [stdout] 2026-04-10T08:03:02.148887Z DEBUG client_fallback:execute_request: interface: Bind interface successfully bind_uri=inet://[::]:0/?alloc_port_id=2 [INFO] [stdout] 2026-04-10T08:03:02.149899Z DEBUG client_fallback:execute_request: interface: Bind interface successfully bind_uri=inet://0.0.0.0:0/?alloc_port_id=3 [INFO] [stdout] 2026-04-10T08:03:02.154527Z DEBUG client_fallback:execute_request: rustls::client::hs: No cached session for DnsName("localhost") [INFO] [stdout] 2026-04-10T08:03:02.154603Z DEBUG client_fallback:execute_request: rustls::client::hs: Not resuming any session [INFO] [stdout] 2026-04-10T08:03:02.155106Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: quic: Starting a new connection [INFO] [stdout] 2026-04-10T08:03:02.155763Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: quic: Add new path pathway=Direct([::]:33106)---Direct([::1]:60208) link=[::]:33106<->[::1]:60208 is_probed=false is_initial_path=true [INFO] [stdout] 2026-04-10T08:03:02.155922Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: quic: Add new path pathway=Direct(0.0.0.0:50723)---Direct(127.0.0.1:60208) link=0.0.0.0:50723<->127.0.0.1:60208 is_probed=false is_initial_path=false [INFO] [stdout] 2026-04-10T08:03:02.156007Z DEBUG client_fallback:execute_request: h3x::pool: QUIC connection established, try to upgrade to H3 [INFO] [stdout] 2026-04-10T08:03:02.161416Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc"}:connection{role=server odcid=3c97b79db9b9f8fc}: quic: Starting a new connection [INFO] [stdout] 2026-04-10T08:03:02.162303Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc"}:connection{role=server odcid=3c97b79db9b9f8fc}: quic: Add new path pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 is_probed=true is_initial_path=true [INFO] [stdout] 2026-04-10T08:03:02.164968Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc"}:connection{role=server odcid=3c97b79db9b9f8fc}: rustls::server::hs: decided upon suite TLS13_AES_256_GCM_SHA384 [INFO] [stdout] 2026-04-10T08:03:02.169835Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc"}:connection{role=server odcid=3c97b79db9b9f8fc}: rustls::server::hs: Chosen ALPN protocol ProtocolName(6833) [INFO] [stdout] 2026-04-10T08:03:02.170546Z  INFO try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc"}:connection{role=server odcid=3c97b79db9b9f8fc}: qconnection::tls: client_name=None [INFO] [stdout] 2026-04-10T08:03:02.172150Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: rustls::client::hs: Using ciphersuite TLS13_AES_256_GCM_SHA384 [INFO] [stdout] 2026-04-10T08:03:02.172216Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: rustls::client::tls13: Not resuming [INFO] [stdout] 2026-04-10T08:03:02.172953Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: rustls::client::tls13: TLS1.3 encrypted extensions: ServerExtensions { server_name_ack: (), selected_protocol: SingleProtocolName(ProtocolName(6833)), transport_parameters: 0704801000000404801000000504801000000604801000000e010a01048000753000083c97b79db9b9f8fc08024064090240640f08c501a98b3ae6cbd6, unknown_extensions: {}, .. } [INFO] [stdout] 2026-04-10T08:03:02.173032Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: rustls::client::hs: ALPN protocol is Some(b"h3") [INFO] [stdout] 2026-04-10T08:03:02.178075Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: quic: TLS handshake finished [INFO] [stdout] 2026-04-10T08:03:02.178154Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: quic: 0-RTT is not enabled, or not accepted by the server. [INFO] [stdout] 2026-04-10T08:03:02.179175Z DEBUG client_fallback:execute_request: h3x::pool: H3 connection established, verifying peer identity [INFO] [stdout] 2026-04-10T08:03:02.179264Z DEBUG client_fallback:execute_request: h3x::pool: Initialed new connection, gogogo [INFO] [stdout] 2026-04-10T08:03:02.179302Z DEBUG client_fallback:execute_request: h3x::pool: (Re)trying to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.179373Z DEBUG client_fallback:execute_request: h3x::client: Connected authority=localhost:60208 [INFO] [stdout] 2026-04-10T08:03:02.179716Z DEBUG client_echo:execute_request: h3x::pool: Entry updated, try to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.179747Z DEBUG client_echo:execute_request: h3x::pool: (Re)trying to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.179780Z DEBUG client_echo:execute_request: h3x::client: Connected authority=localhost:60208 [INFO] [stdout] 2026-04-10T08:03:02.181863Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc"}:connection{role=server odcid=3c97b79db9b9f8fc}: quic: TLS handshake finished [INFO] [stdout] 2026-04-10T08:03:02.181910Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc"}:connection{role=server odcid=3c97b79db9b9f8fc}: quic: 0-RTT is enabled and accepted by the server. [INFO] [stdout] 2026-04-10T08:03:02.182372Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc" server_name="localhost"}: quic_listeners: Accepted incoming connection [INFO] [stdout] 2026-04-10T08:03:02.182553Z DEBUG client_health:execute_request: h3x::pool: Entry updated, try to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.182581Z DEBUG client_health:execute_request: h3x::pool: (Re)trying to reuse connection [INFO] [stdout] 2026-04-10T08:03:02.182610Z DEBUG client_health:execute_request: h3x::client: Connected authority=localhost:60208 [INFO] [stdout] 2026-04-10T08:03:02.183225Z DEBUG server:handle_connection: h3x::server: Accepted new QUIC connection [INFO] [stdout] 2026-04-10T08:03:02.187441Z DEBUG server:handle_connection: h3x::server: Accepted new H3 connection [INFO] [stdout] 2026-04-10T08:03:02.188113Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc" server_name="localhost"}:connection{role=server odcid=3c97b79db9b9f8fc}: quic: Connection state changed new_state=Handshaked [INFO] [stdout] 2026-04-10T08:03:02.189162Z DEBUG server:handle_connection{server_name="localhost"}: h3x::server: Accepted incoming request stream [INFO] [stdout] 2026-04-10T08:03:02.189278Z DEBUG server:handle_connection{server_name="localhost"}: h3x::server: Accepted incoming request stream [INFO] [stdout] 2026-04-10T08:03:02.189370Z DEBUG server:handle_connection{server_name="localhost"}:handle_request{stream_id=0}: h3x::server: Resolving incoming request [INFO] [stdout] 2026-04-10T08:03:02.189430Z DEBUG server:handle_connection{server_name="localhost"}:handle_request{stream_id=4}: h3x::server: Resolving incoming request [INFO] [stdout] 2026-04-10T08:03:02.189682Z DEBUG server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}: h3x::server: Resolved new request [INFO] [stdout] 2026-04-10T08:03:02.189739Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echo service called [INFO] [stdout] 2026-04-10T08:03:02.189804Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(891 bytes) [INFO] [stdout] 2026-04-10T08:03:02.189962Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190043Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190114Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(839 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190188Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(324 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190269Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190368Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190442Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190524Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(265 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190605Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(898 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190683Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.190755Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.198222Z DEBUG client_fallback:execute_request:connection{role=client odcid=3c97b79db9b9f8fc}: quic: Connection state changed new_state=Handshaked [INFO] [stdout] 2026-04-10T08:03:02.199302Z  INFO client_echo: h3x::quic::gm_quic::tests: Request sent [INFO] [stdout] 2026-04-10T08:03:02.199357Z  INFO client_echo: h3x::quic::gm_quic::tests: Response received [INFO] [stdout] 2026-04-10T08:03:02.204839Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(860 bytes) [INFO] [stdout] 2026-04-10T08:03:02.205039Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(303 bytes) [INFO] [stdout] 2026-04-10T08:03:02.205155Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.205283Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(1169 bytes) [INFO] [stdout] 2026-04-10T08:03:02.205420Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=4 method="POST" uri="https://localhost:60208/echo"}:echo_service: h3x::quic::gm_quic::tests: Echoing back request body part(171 bytes) [INFO] [stdout] 2026-04-10T08:03:02.205705Z DEBUG server:handle_connection{server_name="localhost"}:handle_request{stream_id=0 method="GET" uri="https://localhost:60208/not_found"}: h3x::server: Resolved new request [INFO] [stdout] 2026-04-10T08:03:02.205947Z DEBUG server:handle_connection{server_name="localhost"}: h3x::server: Accepted incoming request stream [INFO] [stdout] 2026-04-10T08:03:02.206644Z DEBUG server:handle_connection{server_name="localhost"}:handle_request{stream_id=8}: h3x::server: Resolving incoming request [INFO] [stdout] 2026-04-10T08:03:02.206809Z DEBUG server:handle_connection{server_name="localhost"}:handle_request{stream_id=8 method="GET" uri="https://localhost:60208/health"}: h3x::server: Resolved new request [INFO] [stdout] 2026-04-10T08:03:02.206867Z  INFO server:handle_connection{server_name="localhost"}:handle_request{stream_id=8 method="GET" uri="https://localhost:60208/health"}:health_service: h3x::quic::gm_quic::tests: Health service called [INFO] [stdout] 2026-04-10T08:03:02.208697Z  INFO client_health: h3x::quic::gm_quic::tests: Request sent [INFO] [stdout] 2026-04-10T08:03:02.208861Z  INFO client_fallback: h3x::quic::gm_quic::tests: Request sent [INFO] [stdout] 2026-04-10T08:03:02.214378Z  WARN server:handle_connection{server_name="localhost"}:handle_request{stream_id=0 method="GET" uri="https://localhost:60208/not_found"}: quic: The receiving client side bidirectional stream 0 is not stopped with error before dropped! [INFO] [stdout] 2026-04-10T08:03:02.215003Z DEBUG try_accept_connection{bind_uri=inet://[::1]:0/?alloc_port_id=1 pathway=Direct([::1]:60208)---Direct([::1]:33106) link=[::1]:60208<->[::1]:33106 odcid="3c97b79db9b9f8fc" server_name="localhost"}:connection{role=server odcid=3c97b79db9b9f8fc}: quic: Connection state changed new_state=ApplicationClose(AppError { error_code: VarInt(256), reason: "H3_NO_ERROR (0x100)" }) [INFO] [stdout] test quic::gm_quic::tests::simpl_server ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 24 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.27s [INFO] [stdout] [INFO] [stderr] Doc-tests h3x [INFO] [stdout] [INFO] [stdout] running 16 tests [INFO] [stdout] test src/connection/settings.rs - connection::settings::Setting (line 22) ... ignored [INFO] [stdout] test src/connection/stream.rs - connection::stream::UnidirectionalStream (line 26) ... ignored [INFO] [stdout] test src/qpack/decoder.rs - qpack::decoder::DecoderInstruction::InsertCountIncrement (line 490) ... ignored [INFO] [stdout] test src/qpack/decoder.rs - qpack::decoder::DecoderInstruction::SectionAcknowledgment (line 476) ... ignored [INFO] [stdout] test src/qpack/decoder.rs - qpack::decoder::DecoderInstruction::StreamCancellation (line 483) ... ignored [INFO] [stdout] test src/qpack/encoder.rs - qpack::encoder::EncoderInstruction::Duplicate (line 475) ... ignored [INFO] [stdout] test src/qpack/encoder.rs - qpack::encoder::EncoderInstruction::InsertWithLiteralName (line 457) ... ignored [INFO] [stdout] test src/qpack/encoder.rs - qpack::encoder::EncoderInstruction::InsertWithNameReference (line 441) ... ignored [INFO] [stdout] test src/qpack/encoder.rs - qpack::encoder::EncoderInstruction::SetDynamicTableCapacity (line 434) ... ignored [INFO] [stdout] test src/qpack/field_section.rs - qpack::field_section::EncodedFieldSectionPrefix (line 32) ... ignored [INFO] [stdout] test src/qpack/field_section.rs - qpack::field_section::FieldLineRepresentation::IndexedFieldLine (line 138) ... ignored [INFO] [stdout] test src/qpack/field_section.rs - qpack::field_section::FieldLineRepresentation::IndexedFieldLineWithPostBaseIndex (line 145) ... ignored [INFO] [stdout] test src/qpack/field_section.rs - qpack::field_section::FieldLineRepresentation::LiteralFieldLineWithLiteralName (line 197) ... ignored [INFO] [stdout] test src/qpack/field_section.rs - qpack::field_section::FieldLineRepresentation::LiteralFieldLineWithNameReference (line 152) ... ignored [INFO] [stdout] test src/qpack/field_section.rs - qpack::field_section::FieldLineRepresentation::LiteralFieldLineWithPostBaseNameReference (line 181) ... ignored [INFO] [stdout] test src/../README.md - (line 17) ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 1 passed; 0 failed; 15 ignored; 0 measured; 0 filtered out; finished in 0.51s [INFO] [stdout] [INFO] [stdout] all doctests ran in 0.69s; merged doctests compilation took 0.18s [INFO] running `Command { std: "docker" "inspect" "4a97d63b03d7fed47bd87e1c39eea761d8e45ebc2a8770bb3dfbff9f5338ba98", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "4a97d63b03d7fed47bd87e1c39eea761d8e45ebc2a8770bb3dfbff9f5338ba98", kill_on_drop: false }` [INFO] [stdout] 4a97d63b03d7fed47bd87e1c39eea761d8e45ebc2a8770bb3dfbff9f5338ba98