style(engine): rustfmt — wrap long lines in bridge_tcp test + chunk_context gate (gate fixup)

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
This commit is contained in:
2026-06-12 13:48:53 +02:00
co-authored by Claude Fable 5
parent 408bd39e63
commit 993333facc
2 changed files with 7 additions and 5 deletions
+4 -4
View File
@@ -235,10 +235,10 @@ pub fn derive_chunk_context(
let wavelength_i = (meander_wavelength_m as i32).max(10);
let amplitude_max = (wavelength_i / 4).max(3);
let edge_max = (channel_width / 2).max(2) + 3; // half-width + max edge jitter
// Floor: the BraidedDelta belt reaches anchor ±(32 thread-centre + 4
// thread-half) before warp regardless of wavelength — the band must
// cover it even at the short-wavelength extreme (costs ≤4 m of extra
// gate generosity for the other families).
// Floor: the BraidedDelta belt reaches anchor ±(32 thread-centre + 4
// thread-half) before warp regardless of wavelength — the band must
// cover it even at the short-wavelength extreme (costs ≤4 m of extra
// gate generosity for the other families).
let reach = (amplitude_max + edge_max + LEVEE_BAND_MAX_M).max(32 + 4) + WARP_BOUND_M;
let cross_lo = cross_chunk * CHUNK_M;
let cross_hi = cross_lo + CHUNK_M - 1;
+3 -1
View File
@@ -222,7 +222,9 @@ fn tcp_bridge_eof_mid_frame_escalates_to_disconnected() {
// Client: write 2 of the 4 length-prefix bytes, then die.
use std::io::Write;
let mut stream = TcpStream::connect(server_addr).expect("failed to connect");
stream.write_all(&[0x00, 0x00]).expect("partial write failed");
stream
.write_all(&[0x00, 0x00])
.expect("partial write failed");
stream.flush().expect("flush failed");
thread::sleep(std::time::Duration::from_millis(50));
drop(stream);