File tree 1 file changed +6
-3
lines changed 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change 1
- use std:: time:: Duration ;
1
+ use std:: {
2
+ convert:: Infallible ,
3
+ time:: Duration ,
4
+ } ;
2
5
3
6
use anyhow:: Context ;
4
7
use async_trait:: async_trait;
@@ -77,7 +80,7 @@ struct WebSocketWorker {
77
80
78
81
pub struct WebSocketManager {
79
82
internal_sender : mpsc:: UnboundedSender < WebSocketRequest > ,
80
- worker_handle : JoinHandle < anyhow :: Result < ( ) > > ,
83
+ worker_handle : JoinHandle < Infallible > ,
81
84
}
82
85
impl Drop for WebSocketManager {
83
86
fn drop ( & mut self ) {
@@ -128,7 +131,7 @@ impl WebSocketWorker {
128
131
ws_url : Url ,
129
132
on_response : mpsc:: Sender < ProtocolResponse > ,
130
133
internal_receiver : mpsc:: UnboundedReceiver < WebSocketRequest > ,
131
- ) -> anyhow :: Result < ( ) > {
134
+ ) -> Infallible {
132
135
let ping_ticker = tokio:: time:: interval ( Self :: HEARTBEAT_INTERVAL ) ;
133
136
let backoff = Backoff :: new ( INITIAL_BACKOFF , MAX_BACKOFF ) ;
134
137
You can’t perform that action at this time.
0 commit comments