@@ -1949,6 +1949,7 @@ mod tests {
19491949 use crate :: comm:: CommParams ;
19501950 use crate :: test_util;
19511951
1952+ #[ allow( dead_code) ]
19521953 fn fake_seq_error ( err : anyhow:: Error ) -> Arc < SeqError > {
19531954 Arc :: new ( SeqError {
19541955 seq : 0 . into ( ) ,
@@ -1964,7 +1965,9 @@ mod tests {
19641965 // port -- otherwise an actor failure will cause a crash.
19651966 #[ allow( dead_code) ]
19661967 supervision_rx : PortReceiver < ActorSupervisionEvent > ,
1968+ #[ allow( dead_code) ]
19671969 controller_rx : PortReceiver < ControllerMessage > ,
1970+ #[ allow( dead_code) ]
19681971 controller_actor : ActorRef < ControllerActor > ,
19691972 next_ref : Ref ,
19701973 }
@@ -2040,6 +2043,7 @@ mod tests {
20402043 result
20412044 }
20422045
2046+ #[ allow( dead_code) ]
20432047 async fn validate_dependent_error ( & mut self , reference : Ref , error : Arc < SeqError > ) {
20442048 let result_error = self
20452049 . stream_actor
@@ -2084,6 +2088,7 @@ mod tests {
20842088 }
20852089 }
20862090
2091+ #[ allow( dead_code) ]
20872092 async fn fetch_result (
20882093 cx : & impl context:: Actor ,
20892094 stream_actor : ActorHandle < StreamActor > ,
@@ -2112,6 +2117,7 @@ mod tests {
21122117 . unwrap ( )
21132118 }
21142119
2120+ #[ allow( dead_code) ]
21152121 async fn check_fetch_result_error (
21162122 cx : & impl context:: Actor ,
21172123 stream_actor : ActorHandle < StreamActor > ,
@@ -2140,6 +2146,7 @@ mod tests {
21402146 } ;
21412147 }
21422148
2149+ #[ allow( dead_code) ]
21432150 async fn check_fetch_result_value (
21442151 cx : & impl context:: Actor ,
21452152 stream_actor : ActorHandle < StreamActor > ,
0 commit comments