File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
hyperactor_mesh/src/bootstrap Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -267,7 +267,7 @@ pub mod test_utils {
267267 observer. send ( ( "read" . to_string ( ) , msg. clone ( ) ) ) . unwrap ( ) ;
268268 }
269269 }
270- Ok ( futures:: stream:: iter ( filtered_items. into_iter ( ) ) )
270+ Ok ( futures:: stream:: iter ( filtered_items) )
271271 }
272272
273273 async fn read_one ( & self , seq_id : SeqId ) -> Result < M , MessageLogError > {
Original file line number Diff line number Diff line change @@ -126,13 +126,13 @@ mod tests {
126126 let first = Name :: new ( "first" ) ;
127127 let second = Name :: new ( "second" ) ;
128128 let third = Name :: new ( "third" ) ;
129- let ( first_addr , mut first_rx) = channel:: serve :: < MessageEnvelope > (
129+ let ( _first_addr , mut first_rx) = channel:: serve :: < MessageEnvelope > (
130130 format ! ( "unix:{}/{}" , dir. path( ) . display( ) , first)
131131 . parse ( )
132132 . unwrap ( ) ,
133133 )
134134 . unwrap ( ) ;
135- let ( second_addr , mut second_rx ) = channel:: serve :: < MessageEnvelope > (
135+ let ( _second_addr , _second_rx ) = channel:: serve :: < MessageEnvelope > (
136136 format ! ( "unix:{}/{}" , dir. path( ) . display( ) , second)
137137 . parse ( )
138138 . unwrap ( ) ,
You can’t perform that action at this time.
0 commit comments