com.englishtown.vertx.solr.streams.impl

Class WriteJsonStreamBase<T extends WriteJsonStreamBase>

java.lang.Object

com.englishtown.vertx.solr.streams.impl.WriteJsonStreamBase<T>

All Implemented Interfaces:

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

public abstract class WriteJsonStreamBase<T extends WriteJsonStreamBase>
extends Object
implements WriteJsonStream<T>

Abstract default implementation of WriteJsonStream

Field Summary

Fields

Modifier and Type	Field and Description
protected org.vertx.java.core.Handler<Void>	drainHandler
protected org.vertx.java.core.Handler<Throwable>	exceptionHandler

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WriteJsonStreamBase()

Method Summary

Modifier and Type	Method and Description
T	drainHandler(org.vertx.java.core.Handler<Void> drainHandler)
T	exceptionHandler(org.vertx.java.core.Handler<Throwable> exceptionHandler)
abstract T	handleEnd()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.englishtown.vertx.solr.streams.WriteJsonStream

write

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

setWriteQueueMaxSize, writeQueueFull

Field Detail

exceptionHandler

protected org.vertx.java.core.Handler<Throwable> exceptionHandler

drainHandler

protected org.vertx.java.core.Handler<Void> drainHandler

Constructor Detail

WriteJsonStreamBase

protected WriteJsonStreamBase()

Method Detail

drainHandler

public T drainHandler(org.vertx.java.core.Handler<Void> drainHandler)

Specified by:

drainHandler in interface org.vertx.java.core.streams.DrainSupport<T extends WriteJsonStreamBase>

exceptionHandler

public T exceptionHandler(org.vertx.java.core.Handler<Throwable> exceptionHandler)

Specified by:

exceptionHandler in interface org.vertx.java.core.streams.ExceptionSupport<T extends WriteJsonStreamBase>

handleEnd

public abstract T handleEnd()