net.bluemind.core.rest.vertx

Class VertxStreamProducer

java.lang.Object

net.bluemind.core.rest.vertx.VertxStreamProducer

All Implemented Interfaces:

Stream, org.vertx.java.core.streams.DrainSupport<VertxStreamProducer>, org.vertx.java.core.streams.ExceptionSupport<VertxStreamProducer>, org.vertx.java.core.streams.WriteStream<VertxStreamProducer>

public class VertxStreamProducer
extends java.lang.Object
implements org.vertx.java.core.streams.WriteStream<VertxStreamProducer>, Stream

Field Summary

Fields

Modifier and Type	Field and Description
boolean	writeQueueFull

Constructor Summary

Constructors

Constructor and Description
VertxStreamProducer(org.vertx.java.core.Vertx vertx, java.lang.String streamAddress)

Method Summary

Modifier and Type	Method and Description
void	closed()
protected void	drain()
VertxStreamProducer	drainHandler(org.vertx.java.core.Handler<java.lang.Void> handler)
VertxStreamProducer	exceptionHandler(org.vertx.java.core.Handler<java.lang.Throwable> handler)
void	sendEnd()
VertxStreamProducer	setWriteQueueMaxSize(int maxSize)
static void	stream(org.vertx.java.core.Vertx vertx, java.lang.String controlAdr, org.vertx.java.core.streams.ReadStream<?> bodyStream)
VertxStreamProducer	write(org.vertx.java.core.buffer.Buffer data)
boolean	writeQueueFull()

Methods inherited from class java.lang.Object

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

Field Detail

writeQueueFull

public boolean writeQueueFull

Constructor Detail

VertxStreamProducer

public VertxStreamProducer(org.vertx.java.core.Vertx vertx,
                           java.lang.String streamAddress)

Method Detail

exceptionHandler

public VertxStreamProducer exceptionHandler(org.vertx.java.core.Handler<java.lang.Throwable> handler)

Specified by:

exceptionHandler in interface org.vertx.java.core.streams.ExceptionSupport<VertxStreamProducer>

setWriteQueueMaxSize

public VertxStreamProducer setWriteQueueMaxSize(int maxSize)

Specified by:

setWriteQueueMaxSize in interface org.vertx.java.core.streams.DrainSupport<VertxStreamProducer>

writeQueueFull

public boolean writeQueueFull()

Specified by:

writeQueueFull in interface org.vertx.java.core.streams.DrainSupport<VertxStreamProducer>

drainHandler

public VertxStreamProducer drainHandler(org.vertx.java.core.Handler<java.lang.Void> handler)

Specified by:

drainHandler in interface org.vertx.java.core.streams.DrainSupport<VertxStreamProducer>

write

public VertxStreamProducer write(org.vertx.java.core.buffer.Buffer data)

Specified by:

write in interface org.vertx.java.core.streams.WriteStream<VertxStreamProducer>

drain

protected void drain()

sendEnd

public void sendEnd()

stream

public static void stream(org.vertx.java.core.Vertx vertx,
                          java.lang.String controlAdr,
                          org.vertx.java.core.streams.ReadStream<?> bodyStream)

closed

public void closed()