Fix Rust clippy for cancellation tests

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: bmehta001

sdk/rust/src/detail/core_interop.rs

@@ -235,38 +235,6 @@ impl<'a> StreamingCallbackState<'a> {
     }
 }
 
-#[cfg(test)]
-mod tests {
-    use super::StreamingCallbackState;
-    use std::sync::{
-        atomic::{AtomicBool, Ordering},
-        Arc,
-    };
-
-    #[test]
-    fn cancellation_request_after_callback_is_not_observed_until_next_callback() {
-        let cancel_flag = Arc::new(AtomicBool::new(false));
-        let mut callback = |_chunk: &str| {};
-        let mut state =
-            StreamingCallbackState::with_cancel(&mut callback, Arc::clone(&cancel_flag));
-
-        state.push(b"100");
-        cancel_flag.store(true, Ordering::Relaxed);
-
-        assert!(!state.cancellation_observed());
-    }
-
-    #[test]
-    fn cancellation_is_recorded_when_callback_observes_cancel_flag() {
-        let cancel_flag = Arc::new(AtomicBool::new(true));
-        let mut callback = |_chunk: &str| {};
-        let mut state = StreamingCallbackState::with_cancel(&mut callback, cancel_flag);
-
-        assert!(state.mark_cancelled_if_requested());
-        assert!(state.cancellation_observed());
-    }
-}
-
 ///
 /// * `data` must be a valid pointer to `length` bytes of UTF-8 (or at least
 ///   valid memory) allocated by the native core, valid for the duration of
@@ -836,3 +804,35 @@ impl CoreInterop {
         Ok(libs)
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use super::StreamingCallbackState;
+    use std::sync::{
+        atomic::{AtomicBool, Ordering},
+        Arc,
+    };
+
+    #[test]
+    fn cancellation_request_after_callback_is_not_observed_until_next_callback() {
+        let cancel_flag = Arc::new(AtomicBool::new(false));
+        let mut callback = |_chunk: &str| {};
+        let mut state =
+            StreamingCallbackState::with_cancel(&mut callback, Arc::clone(&cancel_flag));
+
+        state.push(b"100");
+        cancel_flag.store(true, Ordering::Relaxed);
+
+        assert!(!state.cancellation_observed());
+    }
+
+    #[test]
+    fn cancellation_is_recorded_when_callback_observes_cancel_flag() {
+        let cancel_flag = Arc::new(AtomicBool::new(true));
+        let mut callback = |_chunk: &str| {};
+        let mut state = StreamingCallbackState::with_cancel(&mut callback, cancel_flag);
+
+        assert!(state.mark_cancelled_if_requested());
+        assert!(state.cancellation_observed());
+    }
+}