Package org.jgroups.protocols.kubernetes.stream

Class OpenStream

java.lang.Object

org.jgroups.protocols.kubernetes.stream.OpenStream

All Implemented Interfaces:

Callable<InputStream>

public class OpenStream
extends Object
implements Callable<InputStream>

Constructor Summary

Constructors

Constructor	Description
OpenStream(StreamProvider streamProvider, String url, Map<String,String> headers, int connectTimeout, int readTimeout)

Method Summary

Modifier and Type	Method	Description
InputStream	call()

Methods inherited from class java.lang.Object

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

Constructor Details

OpenStream

public OpenStream(StreamProvider streamProvider,
 String url,
 Map<String,String> headers,
 int connectTimeout,
 int readTimeout)

Method Details

call

public InputStream call()
                 throws Exception

Specified by:

call in interface Callable<InputStream>

Throws:

Exception