File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -101,7 +101,7 @@ impl ReplyPrimitives {
101101 match self {
102102 ReplyPrimitives :: Local ( local) => key_expr. to_wire_local ( & local. session ) . to_owned ( ) ,
103103 ReplyPrimitives :: Remote ( remote) => match & remote. session {
104- Some ( s) => key_expr. to_wire ( & s) . to_owned ( ) ,
104+ Some ( s) => key_expr. to_wire ( s) . to_owned ( ) ,
105105 None => WireExpr {
106106 scope : 0 ,
107107 suffix : std:: borrow:: Cow :: Owned ( key_expr. as_str ( ) . into ( ) ) ,
Original file line number Diff line number Diff line change @@ -28,7 +28,7 @@ impl ReplyTestPrimitives {
2828 }
2929 }
3030
31- fn wire_expr ( & self ) -> Option < WireExpr > {
31+ fn wire_expr ( & self ) -> Option < WireExpr < ' _ > > {
3232 self . wire_expr . lock ( ) . unwrap ( ) . clone ( )
3333 }
3434}
@@ -81,14 +81,14 @@ async fn test_reply_preserves_optimized_ke() {
8181
8282 let ke = "test/reply_declared_ke" ;
8383 let declared_ke = ztimeout ! ( session. declare_keyexpr( ke) ) . unwrap ( ) ;
84- let _ = ztimeout ! ( query. reply( declared_ke, "payload" ) ) . unwrap ( ) ;
84+ ztimeout ! ( query. reply( declared_ke, "payload" ) ) . unwrap ( ) ;
8585
8686 let mut we = primitives. wire_expr ( ) . unwrap ( ) ;
8787 assert ! ( we. suffix. is_empty( ) ) ;
8888 assert ! ( we. scope != 0 ) ;
8989 assert ! ( we. mapping == Mapping :: Sender ) ;
9090
91- let _ = ztimeout ! ( query. reply( ke, "payload" ) ) . unwrap ( ) ;
91+ ztimeout ! ( query. reply( ke, "payload" ) ) . unwrap ( ) ;
9292 we = primitives. wire_expr ( ) . unwrap ( ) ;
9393 assert_eq ! ( & we. suffix, & ke) ;
9494 assert ! ( we. scope == 0 ) ;
You can’t perform that action at this time.
0 commit comments