wboayue / rust-ibapi / 25244164015

93%

Build Type

push

github

Committed by web-flow

Commit Message

test(transport): async MemoryStream spike (PR 1/5) (#473)

* test(transport): async MemoryStream spike (PR 1 of MockGateway elimination)

Validates AsyncRead/AsyncWrite over Mutex<VecDeque<u8>> with explicit
Waker registration. Round-trip test pends the reader, yields, pushes a
length-prefixed frame from a producer task, confirms the waker resumes
the read without busy-spinning. Also covers EOF via close().

Not yet wired into AsyncConnection — gates the PR 2 design per
todos/eliminate-mock-gateway.md.

* test(transport): address review nits on async memory spike

- Move inline tests to sibling async_memory_tests.rs per CLAUDE.md item 13
- Drop redundant file-level cfgs (mod declaration in transport/mod.rs already
  gates on test+async)
- Pin tokio::test(flavor = "current_thread") so the producer task can't race
  ahead of the consumer's park, preserving waker-path coverage

* test(transport): reuse encode_raw_length, drop redundant new()

push_frame was hand-rolling the same 4-byte BE length + payload framing
that messages::encode_raw_length already provides; call the helper.
new() was a stylistic alias for default() with #[derive(Default)] in
scope — drop it and use Default::default() directly in the test.

Coverage Stats

49 of 56 new or added lines in 1 file covered. (87.5%)

1 existing line in 1 file now uncovered.

17942 of 19994 relevant lines covered (89.74%)

39.67 hits per line