Package io.gravitee.gateway.api.stream

Class SimpleReadWriteStream<T>

java.lang.Object

io.gravitee.gateway.api.stream.SimpleReadWriteStream<T>

All Implemented Interfaces:

ReadStream<T>, ReadWriteStream<T>, WriteStream<T>

Direct Known Subclasses:

BufferedReadWriteStream

public abstract class SimpleReadWriteStream<T>
extends Object
implements ReadWriteStream<T>

Author:

David BRASSELY (david at gravitee.io), GraviteeSource Team

Field Summary

Fields

Modifier and Type	Field	Description
protected Handler<T>	bodyHandler
protected Handler<Void>	endHandler

Constructor Summary

Constructors

Constructor	Description
SimpleReadWriteStream()

Method Summary

Modifier and Type	Method	Description
SimpleReadWriteStream<T>	bodyHandler(Handler<T> bodyHandler)
void	end()
SimpleReadWriteStream<T>	endHandler(Handler<Void> endHandler)
SimpleReadWriteStream<T>	write(T content)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.gravitee.gateway.api.stream.ReadStream

pause, resume

Methods inherited from interface io.gravitee.gateway.api.stream.WriteStream

drainHandler, end, writeQueueFull

Field Details

bodyHandler

protected Handler<T> bodyHandler

endHandler

protected Handler<Void> endHandler

Constructor Details

SimpleReadWriteStream

public SimpleReadWriteStream()

Method Details

bodyHandler

public SimpleReadWriteStream<T> bodyHandler(Handler<T> bodyHandler)

Specified by:

bodyHandler in interface ReadStream<T>

endHandler

public SimpleReadWriteStream<T> endHandler(Handler<Void> endHandler)

Specified by:

endHandler in interface ReadStream<T>

write

public SimpleReadWriteStream<T> write(T content)

Specified by:

write in interface WriteStream<T>

end

public void end()

Specified by:

end in interface WriteStream<T>