Package org.jgrapes.io.util

Class ManagedBufferStreamer

java.lang.Object

org.jgrapes.io.util.ManagedBufferStreamer

All Implemented Interfaces:

InputConsumer

Direct Known Subclasses:

JsonReader

public class ManagedBufferStreamer
extends Object
implements InputConsumer

Starts a thread with a synchronous consumer of input provided by a Reader which is fed with data from ManagedBuffers (usually obtained from Input events).

Since:

2.8.0

Constructor Summary

Constructors

Constructor	Description
ManagedBufferStreamer(Consumer<Reader> processor)	Instantiates a new managed buffer streamer.

Method Summary

Modifier and Type	Method	Description
ManagedBufferStreamer	charset(Charset charset)	Sets the charset to be used if feed(ManagedBuffer) is invoked with ManagedBuffer<ByteBuffer>.
<W extends Buffer> void	feed(ManagedBuffer<W> buffer)	Feed data to underlying the reader (see {@link ManagedBufferReader#feed).

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgrapes.io.util.InputConsumer

feed

Constructor Details

ManagedBufferStreamer

public ManagedBufferStreamer(Consumer<Reader> processor)

Instantiates a new managed buffer streamer.

Parameters:

processor - the processor

Method Details

charset

public ManagedBufferStreamer charset(Charset charset)

Sets the charset to be used if feed(ManagedBuffer) is invoked with ManagedBuffer<ByteBuffer>.

Defaults to UTF-8. Must be set before the first invocation of feed(ManagedBuffer).

Parameters:

charset - the charset

Returns:

the managed buffer streamer

feed

public <W extends Buffer> void feed(ManagedBuffer<W> buffer)

Feed data to underlying the reader (see {@link ManagedBufferReader#feed).

Specified by:

feed in interface InputConsumer

Parameters:

buffer - the buffer

Throws:

IOException - Signals that an I/O exception has occurred.