net.bluemind.backend.mail.parsing

Class EZInputStreamAdapter

java.lang.Object

net.bluemind.backend.mail.parsing.EZInputStreamAdapter

public class EZInputStreamAdapter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
EZInputStreamAdapter()

Method Summary

Modifier and Type	Method and Description
static <T> java.util.concurrent.CompletableFuture<T>	consume(Stream stream, java.util.function.Function<com.google.common.io.CountingInputStream,T> streamConsumer) Provides an InputStream from a bluemind Stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EZInputStreamAdapter

public EZInputStreamAdapter()

Method Detail

consume

public static <T> java.util.concurrent.CompletableFuture<T> consume(Stream stream,
                                                                    java.util.function.Function<com.google.common.io.CountingInputStream,T> streamConsumer)

Provides an InputStream from a bluemind Stream.

Parameters:

stream - the stream to adapt as in InputStream

streamConsumer - the consumer will get a CountingInputStream and can safely perform blocking reads as it is invoked from a dedicated thread.

Returns: