Use shared builder in stream-end tests

Author: leynos

tests/push_policies.rs

@@ -18,10 +18,15 @@ fn rt() -> Runtime {
         .expect("failed to build test runtime")
 }
 
+#[expect(
+    unused_braces,
+    reason = "rustc false positive for single-line rstest fixtures"
+)]
+// allow(unfulfilled_lint_expectations): rustc occasionally fails to emit the expected
+// lint for single-line rstest fixtures on stable.
+#[allow(unfulfilled_lint_expectations)]
 #[fixture]
-fn builder() -> PushQueuesBuilder<u8> {
-    support::builder::<u8>()
-}
+fn builder() -> PushQueuesBuilder<u8> { support::builder::<u8>() }
 
 /// Verifies how queue policies log and drop when the queue is full.
 #[rstest]

tests/session_registry.rs

@@ -5,11 +5,23 @@ use wireframe::{
     session::{ConnectionId, SessionRegistry},
 };
 
+#[expect(
+    unused_braces,
+    reason = "rustc false positive for single-line rstest fixtures"
+)]
+// allow(unfulfilled_lint_expectations): rustc occasionally fails to emit the expected
+// lint for single-line rstest fixtures on stable.
+#[allow(unfulfilled_lint_expectations)]
 #[fixture]
-fn registry() -> SessionRegistry<u8> {
-    SessionRegistry::default()
-}
+fn registry() -> SessionRegistry<u8> { SessionRegistry::default() }
 
+#[expect(
+    unused_braces,
+    reason = "rustc false positive for single-line rstest fixtures"
+)]
+// allow(unfulfilled_lint_expectations): rustc occasionally fails to emit the expected
+// lint for single-line rstest fixtures on stable.
+#[allow(unfulfilled_lint_expectations)]
 #[fixture]
 fn push_setup() -> (PushQueues<u8>, PushHandle<u8>) {
     PushQueues::<u8>::builder()

tests/stream_end.rs

@@ -1,4 +1,7 @@
 //! Tests for explicit end-of-stream signalling.
+
+mod support;
+
 use std::sync::Arc;
 
 use async_stream::try_stream;
@@ -17,9 +20,7 @@ use terminator::Terminator;
 
 #[fixture]
 fn queues() -> (PushQueues<u8>, PushHandle<u8>) {
-    PushQueues::<u8>::builder()
-        .high_capacity(1)
-        .low_capacity(1)
+    support::builder::<u8>()
         .build()
         .expect("failed to build PushQueues")
 }