File tree Expand file tree Collapse file tree 2 files changed +10
-13
lines changed Expand file tree Collapse file tree 2 files changed +10
-13
lines changed Original file line number Diff line number Diff line change @@ -43,9 +43,9 @@ pub async fn basic_topic(builder: pubsub::builder::topic_admin::ClientBuilder) -
43
43
. send ( )
44
44
. await ?;
45
45
tracing:: info!( "success with list_topics={topics:?}" ) ;
46
- assert ! ( topics. topics. iter( ) . any( |x| x. name == topic. name. clone ( ) ) ) ;
46
+ assert ! ( topics. topics. iter( ) . any( |x| x. name == topic. name) ) ;
47
47
48
- cleanup_test_topic ( topic_admin, topic. name . clone ( ) ) . await ?;
48
+ cleanup_test_topic ( topic_admin, topic. name ) . await ?;
49
49
50
50
Ok ( ( ) )
51
51
}
@@ -68,12 +68,12 @@ pub async fn create_test_topic() -> Result<(TopicAdmin, Topic)> {
68
68
. with_tracing ( )
69
69
. build ( )
70
70
. await ?;
71
- let topic_id = random_topic_id ( project. clone ( ) ) ;
71
+ let topic_id = random_topic_id ( project) ;
72
72
73
73
tracing:: info!( "testing create_topic()" ) ;
74
74
let topic = client
75
75
. create_topic ( )
76
- . set_name ( topic_id. clone ( ) )
76
+ . set_name ( topic_id)
77
77
. set_labels ( [ ( "integration-test" , "true" ) ] )
78
78
. send ( )
79
79
. await ?;
Original file line number Diff line number Diff line change @@ -47,16 +47,13 @@ mod driver {
47
47
. map_err ( integration_tests:: report_error)
48
48
}
49
49
50
- #[ test_case( pubsub:: client:: TopicAdmin :: builder( ) ; "default" ) ]
51
- #[ test_case( pubsub:: client:: TopicAdmin :: builder( ) . with_tracing( ) ; "with tracing enabled" ) ]
52
- #[ test_case( pubsub:: client:: TopicAdmin :: builder( ) . with_retry_policy( retry_policy( ) ) ; "with retry enabled" ) ]
53
50
#[ tokio:: test( flavor = "multi_thread" , worker_threads = 1 ) ]
54
- async fn run_pubsub_basic_topic (
55
- builder : pubsub:: builder :: topic_admin :: ClientBuilder ,
56
- ) -> integration_tests :: Result < ( ) > {
57
- integration_tests :: pubsub :: basic_topic ( builder )
58
- . await
59
- . map_err ( integration_tests:: report_error)
51
+ async fn run_pubsub_basic_topic ( ) -> integration_tests :: Result < ( ) > {
52
+ integration_tests :: pubsub:: basic_topic (
53
+ pubsub :: client :: TopicAdmin :: builder ( ) . with_retry_policy ( retry_policy ( ) ) ,
54
+ )
55
+ . await
56
+ . map_err ( integration_tests:: report_error)
60
57
}
61
58
62
59
#[ test_case( sm:: client:: SecretManagerService :: builder( ) ; "default" ) ]
You can’t perform that action at this time.
0 commit comments