1- use std:: cell:: RefCell ;
21use std:: sync:: Arc ;
3- use std:: thread:: JoinHandle ;
42use std:: time:: Duration ;
53
64use futures:: { StreamExt , TryStreamExt } ;
75use serde:: { Deserialize , Serialize } ;
86use tokio:: io:: AsyncBufReadExt ;
9- use tokio:: spawn;
10- use tokio:: sync:: RwLock ;
11- use tokio:: task:: { self , spawn_local, AbortHandle , LocalSet } ;
7+ use tokio:: task:: { self , spawn_local, LocalSet } ;
128use tokio:: {
139 select,
14- sync:: { mpsc, oneshot, watch } ,
10+ sync:: { mpsc, oneshot} ,
1511} ;
1612use tokio_stream:: wrappers:: LinesStream ;
1713use tracing:: { debug, error, info} ;
1814
19- use crate :: credentials:: { Credential , Credentials } ;
20- use crate :: http_client:: { HttpClient , NullableClient } ;
21- use crate :: output_tracker:: OutputTracker ;
22- use crate :: { models, Error , SharedEnv } ;
23- use tokio:: time:: timeout;
24-
25- const CONNECT_TIMEOUT : std:: time:: Duration = std:: time:: Duration :: from_secs ( 15 ) ;
26- const TIMEOUT : std:: time:: Duration = std:: time:: Duration :: from_secs ( 240 ) ; // 4 minutes
15+ use crate :: credentials:: Credentials ;
16+ use crate :: http_client:: HttpClient ;
17+ use crate :: { models, Error } ;
2718
2819#[ derive( Clone , Debug , Serialize , Deserialize ) ]
2920#[ serde( tag = "event" ) ]
@@ -246,8 +237,6 @@ pub struct ListenerHandle {
246237 pub events : async_channel:: Receiver < ListenerEvent > ,
247238 pub config : ListenerConfig ,
248239 pub commands : mpsc:: Sender < ListenerCommand > ,
249- join_handle : Arc < Option < task:: JoinHandle < ( ) > > > ,
250- listener_actor : Arc < RwLock < Option < ListenerActor > > > ,
251240}
252241
253242impl ListenerHandle {
@@ -275,8 +264,6 @@ impl ListenerHandle {
275264 events : event_rx,
276265 config,
277266 commands : commands_tx,
278- listener_actor : Arc :: new ( RwLock :: new ( None ) ) ,
279- join_handle : Arc :: new ( None ) ,
280267 }
281268 }
282269
@@ -296,7 +283,8 @@ mod tests {
296283 use models:: Subscription ;
297284 use serde_json:: json;
298285 use task:: LocalSet ;
299- use tokio_stream:: wrappers:: WatchStream ;
286+
287+ use crate :: http_client:: NullableClient ;
300288
301289 use super :: * ;
302290
@@ -323,7 +311,7 @@ mod tests {
323311 since : 0 ,
324312 } ;
325313
326- let mut listener = ListenerHandle :: new ( config. clone ( ) ) ;
314+ let listener = ListenerHandle :: new ( config. clone ( ) ) ;
327315 let items: Vec < _ > = listener. events . take ( 3 ) . collect ( ) . await ;
328316
329317 dbg ! ( & items) ;
@@ -369,7 +357,7 @@ mod tests {
369357 since : 0 ,
370358 } ;
371359
372- let mut listener = ListenerHandle :: new ( config. clone ( ) ) ;
360+ let listener = ListenerHandle :: new ( config. clone ( ) ) ;
373361 let items: Vec < _ > = listener. events . take ( 3 ) . collect ( ) . await ;
374362
375363 dbg ! ( & items) ;
@@ -400,7 +388,7 @@ mod tests {
400388 since : 0 ,
401389 } ;
402390
403- let mut listener = ListenerHandle :: new ( config. clone ( ) ) ;
391+ let listener = ListenerHandle :: new ( config. clone ( ) ) ;
404392
405393 // assert_event_matches!(listener, ListenerEvent::Connected { .. },);
406394 } ) ;
0 commit comments