@@ -45,7 +45,7 @@ async fn key_value_get_set() {
45
45
async fn receive_message_subscribed_channel ( ) {
46
46
let ( addr, _) = start_server ( ) . await ;
47
47
48
- let client = Client :: connect ( addr. clone ( ) ) . await . unwrap ( ) ;
48
+ let client = Client :: connect ( addr) . await . unwrap ( ) ;
49
49
let mut subscriber = client. subscribe ( vec ! [ "hello" . into( ) ] ) . await . unwrap ( ) ;
50
50
51
51
tokio:: spawn ( async move {
@@ -63,7 +63,7 @@ async fn receive_message_subscribed_channel() {
63
63
async fn receive_message_multiple_subscribed_channels ( ) {
64
64
let ( addr, _) = start_server ( ) . await ;
65
65
66
- let client = Client :: connect ( addr. clone ( ) ) . await . unwrap ( ) ;
66
+ let client = Client :: connect ( addr) . await . unwrap ( ) ;
67
67
let mut subscriber = client
68
68
. subscribe ( vec ! [ "hello" . into( ) , "world" . into( ) ] )
69
69
. await
@@ -94,7 +94,7 @@ async fn receive_message_multiple_subscribed_channels() {
94
94
async fn unsubscribes_from_channels ( ) {
95
95
let ( addr, _) = start_server ( ) . await ;
96
96
97
- let client = Client :: connect ( addr. clone ( ) ) . await . unwrap ( ) ;
97
+ let client = Client :: connect ( addr) . await . unwrap ( ) ;
98
98
let mut subscriber = client
99
99
. subscribe ( vec ! [ "hello" . into( ) , "world" . into( ) ] )
100
100
. await
0 commit comments