@@ -15,14 +15,14 @@ use crate::{
1515 } ,
1616} ;
1717use futures_util:: { stream, stream:: StreamExt } ;
18- use std:: sync :: {
19- Arc ,
20- atomic :: { AtomicBool , Ordering } ,
21- } ;
22- use std :: { cell :: RefCell , collections :: HashMap , time :: Duration } ;
23- use temporalio_common :: protos :: temporal :: api :: {
24- namespace :: v1 :: { NamespaceInfo , namespace_info :: Capabilities } ,
25- workflowservice :: v1 :: DescribeNamespaceResponse ,
18+ use std:: {
19+ cell :: RefCell ,
20+ collections :: HashMap ,
21+ sync :: {
22+ Arc ,
23+ atomic :: { AtomicBool , Ordering } ,
24+ } ,
25+ time :: Duration ,
2626} ;
2727use temporalio_common:: {
2828 protos:: {
@@ -41,6 +41,7 @@ use temporalio_common::{
4141 ApplicationFailureInfo , CanceledFailureInfo , Failure , NexusHandlerFailureInfo ,
4242 TimeoutFailureInfo , failure:: FailureInfo ,
4343 } ,
44+ namespace:: v1:: { NamespaceInfo , namespace_info:: Capabilities } ,
4445 nexus:: {
4546 self ,
4647 v1:: {
@@ -50,17 +51,17 @@ use temporalio_common::{
5051 } ,
5152 } ,
5253 workflowservice:: v1:: {
53- PollActivityTaskQueueResponse , PollNexusTaskQueueResponse ,
54- PollWorkflowTaskQueueResponse , RespondActivityTaskCompletedResponse ,
55- RespondNexusTaskCompletedResponse , RespondNexusTaskFailedResponse ,
56- RespondWorkflowTaskCompletedResponse , ShutdownWorkerResponse ,
54+ DescribeNamespaceResponse , PollActivityTaskQueueResponse ,
55+ PollNexusTaskQueueResponse , PollWorkflowTaskQueueResponse ,
56+ RespondActivityTaskCompletedResponse , RespondNexusTaskCompletedResponse ,
57+ RespondNexusTaskFailedResponse , RespondWorkflowTaskCompletedResponse ,
58+ ShutdownWorkerResponse ,
5759 } ,
5860 } ,
5961 } ,
6062 worker:: WorkerTaskTypes ,
6163} ;
62- use tokio:: sync:: Notify ;
63- use tokio:: sync:: { Barrier , watch} ;
64+ use tokio:: sync:: { Barrier , Notify , watch} ;
6465use uuid:: Uuid ;
6566
6667#[ tokio:: test]
0 commit comments