### Question:
ContentReaders { @Deprecated(since = "2.0.0") public static Reader<InputStream> inputStreamReader() { return (publisher, clazz) -> CompletableFuture.completedFuture(new DataChunkInputStream(publisher)); } private  ContentReaders(); static Single<byte[]> readBytes(Publisher<DataChunk> chunks); static Single<String> readString(Publisher<DataChunk> chunks, Charset charset); static Single<String> readURLEncodedString(Publisher<DataChunk> chunks,
            Charset charset); @Deprecated(since = "2.0.0") static Reader<String> stringReader(Charset charset); @Deprecated(since = "2.0.0") static Reader<String> urlEncodedStringReader(Charset charset); @Deprecated(since = "2.0.0") static Reader<byte[]> byteArrayReader(); @Deprecated(since = "2.0.0") static Reader<InputStream> inputStreamReader();  }### Answer:
@Test void test() throws Exception { String original = "Popokatepetl"; byte[] bytes = original.getBytes(StandardCharsets.UTF_8); CompletableFuture<? extends InputStream> future = ContentReaders.inputStreamReader() .apply(Multi.singleton(DataChunk.create(bytes))) .toCompletableFuture(); InputStream inputStream = future.get(10, TimeUnit.SECONDS); byte[] actualBytes = inputStream.readAllBytes(); assertThat(actualBytes, is(bytes)); }