com.hcl.domino.keep.testhelper

Class TestSubscriberGeneric<T>

java.lang.Object

com.hcl.domino.keep.testhelper.TestSubscriberGeneric<T>

Type Parameters:

T - The class we expect from the actual class, mostly JSON

All Implemented Interfaces:

io.reactivex.Emitter<T>, io.reactivex.ObservableEmitter<T>, io.reactivex.Observer<T>

Direct Known Subclasses:

TestSubscriberBuffer, TestSubscriberJson

public class TestSubscriberGeneric<T>
extends java.lang.Object
implements io.reactivex.ObservableEmitter<T>, io.reactivex.Observer<T>

Helper class as subscriber to the request methods allows to specify what behavior is expected by fluently add properties to the constructor e.g.

java TestSubscriberJson sub = new TestSubscriberJson()
.expectFailure()
.errorClass(SomeError.class)
.errorMessage(String message)
.expectedOnNextCount(42)
.minimumOnNextCount(3)
.maximumOnNextCount(100);

When you specify an exact number, maximum and minimum don’t make sense, but will still get reported

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.function.Consumer<T>	_additionalTests

Constructor Summary

Constructors

Constructor and Description
TestSubscriberGeneric() Default constructor

Method Summary

Modifier and Type	Method and Description
void	close() Close connection to check if results are OK
TestSubscriberGeneric<T>	expectedOnNextCount(int expectedOnNextCount) Sets the exact number of returned items we expect default is -1 = no expectations
TestSubscriberGeneric<T>	expectFailure(boolean expectFailure) Specify if we expect the listener to succeed
TestSubscriberGeneric<T>	externalErrorHandling(boolean externalFailureHandling) Specify when an an external Error handler is capturing the error
int	getDataCount()
boolean	isDisposed()
TestSubscriberGeneric<T>	maximumOnNextCount(int maximumOnNextCount) Sets the maximum of returned items we expect, default is -1 = no expectations
TestSubscriberGeneric<T>	minimumOnNextCount(int minimumOnNextCount) Sets the minimum of returned items we expect, default is -1 = no expectations
void	onComplete()
void	onError(java.lang.Throwable error)
void	onNext(T value)
void	onSubscribe(io.reactivex.disposables.Disposable disposable)
io.reactivex.ObservableEmitter<T>	serialize()
TestSubscriberGeneric<T>	setAdditionalTests(java.util.function.Consumer<T> additionalTests) Callback to hook additional tests into the onNext phase of the Subscriber
void	setCancellable(io.reactivex.functions.Cancellable c)
void	setDisposable(io.reactivex.disposables.Disposable d)
boolean	tryOnError(java.lang.Throwable t)

Methods inherited from class java.lang.Object

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

Field Detail

_additionalTests

protected java.util.function.Consumer<T> _additionalTests

Constructor Detail

TestSubscriberGeneric

public TestSubscriberGeneric()

Default constructor

Method Detail

close

public void close()

Close connection to check if results are OK

expectedOnNextCount

public TestSubscriberGeneric<T> expectedOnNextCount(int expectedOnNextCount)

Sets the exact number of returned items we expect default is -1 = no expectations

Parameters:

expectedOnNextCount -

Returns:

fluent

expectFailure

public TestSubscriberGeneric<T> expectFailure(boolean expectFailure)

Specify if we expect the listener to succeed

Parameters:

expectFailure - true if we expect onError but not onNext

Returns:

fluent

externalErrorHandling

public TestSubscriberGeneric<T> externalErrorHandling(boolean externalFailureHandling)

Specify when an an external Error handler is capturing the error

Parameters:

externalFailureHandling - true if we handle errors externally

Returns:

fluent

getDataCount

public int getDataCount()

Returns:

the onNextCount

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface io.reactivex.ObservableEmitter<T>

maximumOnNextCount

public TestSubscriberGeneric<T> maximumOnNextCount(int maximumOnNextCount)

Sets the maximum of returned items we expect, default is -1 = no expectations

Parameters:

maximumOnNextCount -

Returns:

fluent

minimumOnNextCount

public TestSubscriberGeneric<T> minimumOnNextCount(int minimumOnNextCount)

Sets the minimum of returned items we expect, default is -1 = no expectations

Parameters:

minimumOnNextCount -

Returns:

fluent

onComplete

public void onComplete()

Specified by:

onComplete in interface io.reactivex.Emitter<T>

Specified by:

onComplete in interface io.reactivex.Observer<T>

onError

public void onError(java.lang.Throwable error)

Specified by:

onError in interface io.reactivex.Emitter<T>

Specified by:

onError in interface io.reactivex.Observer<T>

onNext

public void onNext(T value)

Specified by:

onNext in interface io.reactivex.Emitter<T>

Specified by:

onNext in interface io.reactivex.Observer<T>

onSubscribe

public void onSubscribe(io.reactivex.disposables.Disposable disposable)

Specified by:

onSubscribe in interface io.reactivex.Observer<T>

serialize

public io.reactivex.ObservableEmitter<T> serialize()

Specified by:

serialize in interface io.reactivex.ObservableEmitter<T>

setAdditionalTests

public TestSubscriberGeneric<T> setAdditionalTests(java.util.function.Consumer<T> additionalTests)

Callback to hook additional tests into the onNext phase of the Subscriber

Parameters:

additionalTests - additional tests and assertions to run

Returns:

fluent

setCancellable

public void setCancellable(io.reactivex.functions.Cancellable c)

Specified by:

setCancellable in interface io.reactivex.ObservableEmitter<T>

setDisposable

public void setDisposable(io.reactivex.disposables.Disposable d)

Specified by:

setDisposable in interface io.reactivex.ObservableEmitter<T>

tryOnError

public boolean tryOnError(java.lang.Throwable t)

Specified by:

tryOnError in interface io.reactivex.ObservableEmitter<T>