com.englishtown.vertx.solr.streams

Interface WriteJsonStream<T>

All Superinterfaces:

org.vertx.java.core.streams.DrainSupport<T>, org.vertx.java.core.streams.ExceptionSupport<T>

All Known Implementing Classes:

WriteJsonStreamBase

public interface WriteJsonStream<T>
extends org.vertx.java.core.streams.ExceptionSupport<T>, org.vertx.java.core.streams.DrainSupport<T>

Represents a stream of Json data that can be written to

Any class that implements this interface can be used by a SolrPump to pump data to it.

This interface exposes a fluent api and the type T represents the type of the object that implements the interface to allow method chaining

Method Summary

Modifier and Type	Method and Description
T	write(org.vertx.java.core.json.JsonObject jsonObject) Write some data to the stream.

Methods inherited from interface org.vertx.java.core.streams.ExceptionSupport

exceptionHandler

Methods inherited from interface org.vertx.java.core.streams.DrainSupport

drainHandler, setWriteQueueMaxSize, writeQueueFull

Method Detail

write

T write(org.vertx.java.core.json.JsonObject jsonObject)

Write some data to the stream. The data is put on an internal write queue, and the write actually happens asynchronously. To avoid running out of memory by putting too much on the write queue, check the DrainSupport.writeQueueFull() method before writing. This is done automatically if using a SolrPump.

Parameters:

jsonObject - JsonObject we write to

Returns:

Returns this