DataChunkInputStream (Helidon Project 2.6.9 API)

java.lang.Object
- java.io.InputStream
- - io.helidon.media.common.DataChunkInputStream

All Implemented Interfaces:

Closeable, AutoCloseable
```
public class DataChunkInputStream
extends InputStream
```
Provides a bridge between a reactive Flow.Publisher in Helidon and an InputStream in Jersey. It subscribes to a Helidon publisher of data chunks and makes the data available to Jersey using the blocking InputStream API. This implementation is documented here /docs-internal/datachunkinputstream.md.

Constructor Summary

Constructors
Constructor	Description
`DataChunkInputStream(Flow.Publisher<DataChunk> originalPublisher)`	Stores publisher for later subscription.
`DataChunkInputStream(Flow.Publisher<DataChunk> originalPublisher, boolean validate)`	Stores publisher for later subscription and sets if executing thread should be validated.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

void close()

int read()

int read(byte[] buf, int off, int len)
- Methods inherited from class java.io.InputStream
  available, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DataChunkInputStream
```
public DataChunkInputStream(Flow.Publisher<DataChunk> originalPublisher)
```
    Stores publisher for later subscription. Disables executing thread validation.
    
    Parameters:
    
    originalPublisher - The original publisher.
  - DataChunkInputStream
```
public DataChunkInputStream(Flow.Publisher<DataChunk> originalPublisher,
                            boolean validate)
```
    Stores publisher for later subscription and sets if executing thread should be validated. If validation is enabled, it asserts if the execution thread is the same as the thread which created this instance and throws an IllegalStateException if it does.
    
    Parameters:
    
    originalPublisher - The original publisher.
    
    validate - executing thread validation
- Method Detail
  - close
```
public void close()
```
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface Closeable
    
    Overrides:
    
    close in class InputStream
  - read
```
public int read()
         throws IOException
```
    Specified by:
    
    read in class InputStream
    
    Throws:
    
    IOException
  - read
```
public int read(byte[] buf,
                int off,
                int len)
         throws IOException
```
    Overrides:
    
    read in class InputStream
    
    Throws:
    
    IOException