@@ -85,7 +85,7 @@ final class K3dConfigMapTests: K3dTestCase {
85
85
deletedConfigMap. fulfill ( )
86
86
}
87
87
88
- wait ( for : [ deletedConfigMap] , timeout: 30 )
88
+ await fulfillment ( of : [ deletedConfigMap] , timeout: 30 )
89
89
}
90
90
91
91
func testWatch( ) async {
@@ -95,7 +95,7 @@ final class K3dConfigMapTests: K3dTestCase {
95
95
var records : [ Record ] = [ ]
96
96
do {
97
97
let watchTask = try K3dTestCase . client. configMaps. watch ( in: . namespace( " cm3 " ) )
98
- for try await event in watchTask. start ( ) {
98
+ for try await event in await watchTask. start ( ) {
99
99
let record = Record ( eventType: event. type, resource: event. resource. metadata!. name!)
100
100
records. append ( record)
101
101
@@ -115,10 +115,10 @@ final class K3dConfigMapTests: K3dTestCase {
115
115
try ? _ = await K3dTestCase . client. configMaps. delete ( inNamespace: . namespace( " cm3 " ) , name: " test1 " )
116
116
try ? _ = await K3dTestCase . client. configMaps. update ( inNamespace: . namespace( " cm3 " ) , buildConfigMap ( " test2 " , data: [ " foo " : " bar " ] ) )
117
117
118
- wait ( for : [ expectation] , timeout: 10 )
118
+ await fulfillment ( of : [ expectation] , timeout: 10 )
119
119
120
120
task. cancel ( )
121
- let result = try ? await task. result. get ( )
121
+ let result = await task. result. get ( )
122
122
123
123
assertEqual ( result, [
124
124
Record ( eventType: . added, resource: " kube-root-ca.crt " ) ,
0 commit comments