@@ -165,7 +165,7 @@ void given_PresignedUrlManager_when_GetObjectWithDifferentHttpResponses_then_Sho
165
165
if (expectSuccess ) {
166
166
assertSuccessfulGetObject (testRequest );
167
167
} else {
168
- assertThatThrownBy (() -> presignedUrlManager .getObject (testRequest ))
168
+ assertThatThrownBy (() -> presignedUrlManager .getObject (testRequest , ResponseTransformer . toInputStream () ))
169
169
.isInstanceOf (expectedExceptionType );
170
170
}
171
171
}
@@ -179,7 +179,7 @@ void given_PresignedUrlManager_when_GetObjectWithDifferentRequestConfigurations_
179
179
PresignedUrlGetObjectRequest .Builder builder = PresignedUrlGetObjectRequest .builder ();
180
180
requestCustomizer .accept (builder );
181
181
PresignedUrlGetObjectRequest request = builder .build ();
182
- ResponseInputStream <GetObjectResponse > result = presignedUrlManager .getObject (request );
182
+ ResponseInputStream <GetObjectResponse > result = presignedUrlManager .getObject (request , ResponseTransformer . toInputStream () );
183
183
assertThat (result ).isNotNull ();
184
184
String content = IoUtils .toUtf8String (result );
185
185
assertThat (content ).isEqualTo (TEST_CONTENT );
@@ -223,7 +223,7 @@ void given_PresignedUrlManager_when_ExecutingDifferentScenarios_then_ShouldBehav
223
223
224
224
case "ENDPOINT_VERIFICATION" :
225
225
mockHttpClient .stubNextResponse (createSuccessResponse ());
226
- presignedUrlManager .getObject (testRequest );
226
+ presignedUrlManager .getObject (testRequest , ResponseTransformer . toInputStream () );
227
227
SdkHttpRequest lastRequest = mockHttpClient .getLastRequest ();
228
228
assertThat (lastRequest .getUri ().toString ()).startsWith (testPresignedUrl .toString ().split ("\\ ?" )[0 ]);
229
229
String presignedUrlQuery = testPresignedUrl .getQuery ();
@@ -245,7 +245,7 @@ void given_PresignedUrlManager_when_ExecutingDifferentScenarios_then_ShouldBehav
245
245
DefaultPresignedUrlManager managerWithMetrics = new DefaultPresignedUrlManager (
246
246
clientHandler , protocolFactory , clientConfigWithMetrics , protocolMetadata );
247
247
mockHttpClient .stubNextResponse (createSuccessResponse ());
248
- managerWithMetrics .getObject (testRequest );
248
+ managerWithMetrics .getObject (testRequest , ResponseTransformer . toInputStream () );
249
249
verify (mockPublisher , atLeastOnce ()).publish (any (MetricCollection .class ));
250
250
ArgumentCaptor <MetricCollection > metricsCaptor = ArgumentCaptor .forClass (MetricCollection .class );
251
251
verify (mockPublisher ).publish (metricsCaptor .capture ());
@@ -300,7 +300,7 @@ private static URL createTestUrl() {
300
300
301
301
private void assertSuccessfulGetObject (PresignedUrlGetObjectRequest request ) {
302
302
try {
303
- ResponseInputStream <GetObjectResponse > result = presignedUrlManager .getObject (request );
303
+ ResponseInputStream <GetObjectResponse > result = presignedUrlManager .getObject (request , ResponseTransformer . toInputStream () );
304
304
assertThat (result ).isNotNull ();
305
305
String content = IoUtils .toUtf8String (result );
306
306
assertThat (content ).isEqualTo (TEST_CONTENT );
0 commit comments