com.hcl.domino.keep.testhelper

Class TestSubscriberBuffer

java.lang.Object

com.hcl.domino.keep.testhelper.TestSubscriberGeneric<io.vertx.core.buffer.Buffer>

com.hcl.domino.keep.testhelper.TestSubscriberBuffer

All Implemented Interfaces:

io.reactivex.Emitter<io.vertx.core.buffer.Buffer>, io.reactivex.ObservableEmitter<io.vertx.core.buffer.Buffer>, io.reactivex.Observer<io.vertx.core.buffer.Buffer>

public class TestSubscriberBuffer
extends TestSubscriberGeneric<io.vertx.core.buffer.Buffer>

Field Summary

Fields inherited from class com.hcl.domino.keep.testhelper.TestSubscriberGeneric

_additionalTests

Constructor Summary

Constructors

Constructor and Description
TestSubscriberBuffer()

Method Summary

Modifier and Type	Method and Description
TestSubscriberBuffer	addExpectedValue(io.vertx.core.buffer.Buffer expected)
void	onComplete()
void	onNext(io.vertx.core.buffer.Buffer value)
TestSubscriberBuffer	setExpectedValue(io.vertx.core.buffer.Buffer expected) Sets the expected value at the end of the operation

Methods inherited from class com.hcl.domino.keep.testhelper.TestSubscriberGeneric

close, expectedOnNextCount, expectFailure, externalErrorHandling, getDataCount, isDisposed, maximumOnNextCount, minimumOnNextCount, onError, onSubscribe, serialize, setAdditionalTests, setCancellable, setDisposable, tryOnError

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSubscriberBuffer

public TestSubscriberBuffer()

Method Detail

addExpectedValue

public TestSubscriberBuffer addExpectedValue(@Nonnull
                                             io.vertx.core.buffer.Buffer expected)

onComplete

public void onComplete()

Specified by:

onComplete in interface io.reactivex.Emitter<io.vertx.core.buffer.Buffer>

Specified by:

onComplete in interface io.reactivex.Observer<io.vertx.core.buffer.Buffer>

Overrides:

onComplete in class TestSubscriberGeneric<io.vertx.core.buffer.Buffer>

onNext

public void onNext(io.vertx.core.buffer.Buffer value)

Specified by:

onNext in interface io.reactivex.Emitter<io.vertx.core.buffer.Buffer>

Specified by:

onNext in interface io.reactivex.Observer<io.vertx.core.buffer.Buffer>

Overrides:

onNext in class TestSubscriberGeneric<io.vertx.core.buffer.Buffer>

setExpectedValue

public TestSubscriberBuffer setExpectedValue(@Nonnull
                                             io.vertx.core.buffer.Buffer expected)

Sets the expected value at the end of the operation

Parameters:

expected -

• expected value

Returns:

fluent