Added AsyncResponseTransformer.toBlockingInputStream.

[millems]

This allows streaming operation responses to be read as if they're an InputStream.

Example usage:

CompletableFuture<ResponseInputStream<GetObjectResponse>> responseFuture =
    s3AsyncClient.getObject(getObjectRequest, AsyncResponseTransformer.toBlockingInputStream());
try (ResponseInputStream<GetObjectResponse> responseStream = responseFuture.join()) {
    responseStream.transferTo(System.out); // BLOCKS the calling thread
}

Other changes made to support this change:

1. Created InputStreamSubscriber, a Subscriber<ByteBuffer> that extends InputStream. It allows subscribing to a publisher and then performing blocking reads against it. This is used by AsyncResponseTransformer.
2. Updated ByteBufferStoringSubscriber to support blockingTransferTo(ByteBuffer). It's like transferTo(ByteBuffer), except that it will block the caller until at least one byte of data is available to be read. This is used by InputStreamSubscriber.
3. Allow ResponseInputStream to store non-abortable streams. This is used by AsyncResponseTransformer.

[sonarcloud]

Kudos, SonarCloud Quality Gate passed!   

0 Bugs
0 Vulnerabilities
0 Security Hotspots
32 Code Smells

90.1% Coverage
0.0% Duplication