@@ -58,16 +58,11 @@ public void create() {
58
58
.name (buildpackName )
59
59
.position (2 )
60
60
.build ())
61
- .map (ResourceUtils ::getEntity )
61
+ .thenMany (requestListBuildpacks (this .cloudFoundryClient , buildpackName ))
62
+ .map (BuildpackResource ::getEntity )
63
+ .map (BuildpackEntity ::getName )
62
64
.as (StepVerifier ::create )
63
- .expectNext (
64
- BuildpackEntity .builder ()
65
- .enabled (false )
66
- .locked (true )
67
- .name (buildpackName )
68
- .position (2 )
69
- .lifecycle (LifecycleType .BUILDPACK )
70
- .build ())
65
+ .expectNext (buildpackName )
71
66
.expectComplete ()
72
67
.verify (Duration .ofMinutes (5 ));
73
68
}
@@ -130,15 +125,9 @@ public void get() {
130
125
.buildpackId (buildpackId )
131
126
.build ()))
132
127
.map (ResourceUtils ::getEntity )
128
+ .map (BuildpackEntity ::getName )
133
129
.as (StepVerifier ::create )
134
- .expectNext (
135
- BuildpackEntity .builder ()
136
- .enabled (false )
137
- .locked (false )
138
- .name (buildpackName )
139
- .position (3 )
140
- .lifecycle (LifecycleType .BUILDPACK )
141
- .build ())
130
+ .expectNext (buildpackName )
142
131
.expectComplete ()
143
132
.verify (Duration .ofMinutes (5 ));
144
133
}
@@ -160,15 +149,9 @@ public void list() {
160
149
.build ()))
161
150
.map (ResourceUtils ::getEntity )
162
151
.filter (entity -> buildpackName .equals (entity .getName ())))
152
+ .map (BuildpackEntity ::getName )
163
153
.as (StepVerifier ::create )
164
- .expectNext (
165
- BuildpackEntity .builder ()
166
- .enabled (false )
167
- .locked (false )
168
- .name (buildpackName )
169
- .position (3 )
170
- .lifecycle (LifecycleType .BUILDPACK )
171
- .build ())
154
+ .expectNext (buildpackName )
172
155
.expectComplete ()
173
156
.verify (Duration .ofMinutes (5 ));
174
157
}
@@ -181,24 +164,19 @@ public void listFilterByName() {
181
164
.flatMapMany (
182
165
buildpackId ->
183
166
PaginationUtils .requestClientV2Resources (
184
- page ->
185
- this .cloudFoundryClient
186
- .buildpacks ()
187
- .list (
188
- ListBuildpacksRequest
189
- .builder ()
190
- .name (buildpackName )
191
- .build ()))
192
- .map (ResourceUtils ::getEntity ))
167
+ page ->
168
+ this .cloudFoundryClient
169
+ .buildpacks ()
170
+ .list (
171
+ ListBuildpacksRequest
172
+ .builder ()
173
+ .name (buildpackName )
174
+ .build ()))
175
+ )
176
+ .map (ResourceUtils ::getEntity )
177
+ .map (BuildpackEntity ::getName )
193
178
.as (StepVerifier ::create )
194
- .expectNext (
195
- BuildpackEntity .builder ()
196
- .enabled (false )
197
- .locked (false )
198
- .name (buildpackName )
199
- .position (3 )
200
- .lifecycle (LifecycleType .BUILDPACK )
201
- .build ())
179
+ .expectNext (buildpackName )
202
180
.expectComplete ()
203
181
.verify (Duration .ofMinutes (5 ));
204
182
}
@@ -221,14 +199,7 @@ public void update() {
221
199
.build ()))
222
200
.map (ResourceUtils ::getEntity )
223
201
.as (StepVerifier ::create )
224
- .expectNext (
225
- BuildpackEntity .builder ()
226
- .enabled (true )
227
- .locked (true )
228
- .name (buildpackName )
229
- .position (2 )
230
- .lifecycle (LifecycleType .BUILDPACK )
231
- .build ())
202
+ .expectNextMatches (b -> b .getEnabled () && b .getLocked () && b .getPosition ().equals (2 ))
232
203
.expectComplete ()
233
204
.verify (Duration .ofMinutes (5 ));
234
205
}
@@ -251,16 +222,9 @@ public void upload() throws IOException {
251
222
.filename (filename )
252
223
.build ()))
253
224
.map (ResourceUtils ::getEntity )
225
+ .map (BuildpackEntity ::getFilename )
254
226
.as (StepVerifier ::create )
255
- .expectNext (
256
- BuildpackEntity .builder ()
257
- .enabled (false )
258
- .filename (filename )
259
- .locked (false )
260
- .name (buildpackName )
261
- .position (3 )
262
- .lifecycle (LifecycleType .BUILDPACK )
263
- .build ())
227
+ .expectNext (filename )
264
228
.expectComplete ()
265
229
.verify (Duration .ofMinutes (5 ));
266
230
}
@@ -283,16 +247,9 @@ public void uploadDirectory() throws IOException {
283
247
.filename (filename )
284
248
.build ()))
285
249
.map (ResourceUtils ::getEntity )
250
+ .map (BuildpackEntity ::getFilename )
286
251
.as (StepVerifier ::create )
287
- .expectNext (
288
- BuildpackEntity .builder ()
289
- .enabled (false )
290
- .filename (filename + ".zip" )
291
- .locked (false )
292
- .name (buildpackName )
293
- .position (3 )
294
- .lifecycle (LifecycleType .BUILDPACK )
295
- .build ())
252
+ .expectNext (filename + ".zip" )
296
253
.expectComplete ()
297
254
.verify (Duration .ofMinutes (5 ));
298
255
}
0 commit comments