net.bluemind.imap.vertx.tests

Class FakeStream

java.lang.Object

net.bluemind.imap.vertx.tests.FakeStream

All Implemented Interfaces:

io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.streams.StreamBase

public class FakeStream
extends java.lang.Object
implements io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

Constructor Summary

Constructors

Constructor and Description
FakeStream(io.vertx.core.Vertx vx, byte[] payload)

Method Summary

Modifier and Type	Method and Description
FakeStream	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
FakeStream	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	fetch(long amount)
FakeStream	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
int	length()
FakeStream	pause()
FakeStream	resume()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.vertx.core.streams.ReadStream

pipe, pipeTo, pipeTo

Constructor Detail

FakeStream

public FakeStream(io.vertx.core.Vertx vx,
                  byte[] payload)

Method Detail

length

public int length()

handler

public FakeStream handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)

Specified by:

handler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

pause

public FakeStream pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

resume

public FakeStream resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

exceptionHandler

public FakeStream exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)

Specified by:

exceptionHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

Specified by:

exceptionHandler in interface io.vertx.core.streams.StreamBase

endHandler

public FakeStream endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

fetch

public io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> fetch(long amount)

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>