File tree Expand file tree Collapse file tree 1 file changed +6
-10
lines changed Expand file tree Collapse file tree 1 file changed +6
-10
lines changed Original file line number Diff line number Diff line change @@ -22,18 +22,15 @@ pub fn connect() -> impl Sipper<Never, Event> {
22
22
Ok ( ( websocket, _) ) => {
23
23
let ( sender, receiver) = mpsc:: channel ( 100 ) ;
24
24
25
- let _ = output
26
- . send ( Event :: Connected ( Connection ( sender) ) )
27
- . await ;
25
+ output. send ( Event :: Connected ( Connection ( sender) ) ) . await ;
28
26
29
27
( websocket. fuse ( ) , receiver)
30
28
}
31
29
Err ( _) => {
32
30
tokio:: time:: sleep ( tokio:: time:: Duration :: from_secs ( 1 ) )
33
31
. await ;
34
32
35
- let _ = output. send ( Event :: Disconnected ) . await ;
36
-
33
+ output. send ( Event :: Disconnected ) . await ;
37
34
continue ;
38
35
}
39
36
} ;
@@ -43,21 +40,20 @@ pub fn connect() -> impl Sipper<Never, Event> {
43
40
received = websocket. select_next_some( ) => {
44
41
match received {
45
42
Ok ( tungstenite:: Message :: Text ( message) ) => {
46
- let _ = output. send( Event :: MessageReceived ( Message :: User ( message) ) ) . await ;
43
+ output. send( Event :: MessageReceived ( Message :: User ( message) ) ) . await ;
47
44
}
48
45
Err ( _) => {
49
- let _ = output. send( Event :: Disconnected ) . await ;
46
+ output. send( Event :: Disconnected ) . await ;
50
47
break ;
51
48
}
52
- Ok ( _) => continue ,
49
+ Ok ( _) => { } ,
53
50
}
54
51
}
55
-
56
52
message = input. select_next_some( ) => {
57
53
let result = websocket. send( tungstenite:: Message :: Text ( message. to_string( ) ) ) . await ;
58
54
59
55
if result. is_err( ) {
60
- let _ = output. send( Event :: Disconnected ) . await ;
56
+ output. send( Event :: Disconnected ) . await ;
61
57
}
62
58
}
63
59
}
You can’t perform that action at this time.
0 commit comments