Package com.streambase.sb.unittest

Class Expecter

java.lang.Object

com.streambase.sb.unittest.Expecter

public class Expecter
extends Object

An Expecter is used for expecting tuples from a Dequeuer.

Since:

6.6

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Expecter.AbstractPredicate	Subclass this and override isExpected(Tuple t) to simplify creating predicates.
static class	Expecter.DequeueSetting	Dequeue settings
static interface	Expecter.Predicate	To expect tuples by predicate, implement this interface.

Constructor Summary

Constructors

Constructor	Description
Expecter(Dequeuer stream)	Constructor
Expecter(Dequeuer stream, TupleComparator comparator)	Constructor

Method Summary

Modifier and Type	Method	Description
void	expect(Tuple tuple)	Expect a tuple from the dequeuer.
void	expect(Tuple... tuples)	Expect multiple tuples in a particular order from the dequeuer.
void	expect(Expecter.DequeueSetting mode, Tuple expected)	Expect a given tuple from the dequeuer
void	expect(Expecter.DequeueSetting mode, Tuple... tuples)	Expect multiple tuples in a particular order from the dequeuer
<T> void	expect(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, List<T> t)	Expect a tuple from the dequeuer
<T> void	expect(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T t)	Expect a tuple from the dequeuer
<T> void	expect(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T... t)	Expect a tuple from the dequeuer
void	expect(Expecter.DequeueSetting mode, List<Tuple> expected)	Expect multiple tuples in a particular order from the dequeuer
<T> void	expect(TupleMaker<T> tupleMaker, List<T> t)	Expect multiple tuples in a particular order from the dequeuer.
<T> void	expect(TupleMaker<T> tupleMaker, T t)	Expect a tuple from the dequeuer.
<T> void	expect(TupleMaker<T> tupleMaker, T... t)	Expect multiple tuples in a particular order from the dequeuer.
void	expect(List<Tuple> expected)	Expect multiple tuples in a particular order from the dequeuer.
void	expectNothing()	Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.
void	expectNothing(long time, TimeUnit unit)	Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.
void	expectPredicate(Expecter.DequeueSetting mode, Expecter.Predicate p)	Expect a tuple that fulfills the given predicate from the dequeuer
void	expectPredicate(Expecter.DequeueSetting mode, List<Expecter.Predicate> expected)	Expect a number of tuples, each fulfilling one predicate in a list, from the Dequeuer
void	expectUnordered(Tuple... expected)	Expect multiple tuples in any order from the dequeuer.
void	expectUnordered(Expecter.DequeueSetting mode, Tuple... expected)	Expect multiple tuples in any order from the dequeuer
<T> void	expectUnordered(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, List<T> t)	Expect multiple tuples in any order from the dequeuer
<T> void	expectUnordered(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T... t)	Expect multiple tuples in any order from the dequeuer
void	expectUnordered(Expecter.DequeueSetting mode, List<Tuple> expected)	Expect multiple tuples in any order from the dequeuer
<T> void	expectUnordered(TupleMaker<T> tupleMaker, List<T> t)	Expect multiple tuples in any order from the dequeuer.
<T> void	expectUnordered(TupleMaker<T> tupleMaker, T... t)	Expect multiple tuples in any order from the dequeuer.
void	expectUnordered(List<Tuple> expected)	Expect multiple tuples in any order from the dequeuer.
void	expectUnorderedPredicate(Expecter.DequeueSetting mode, List<Expecter.Predicate> expected)	Expect tuples that fulfill multiple predicates in any order from the dequeuer
long	getTimeout(TimeUnit unit)	get the timeout that the expector will use for each call to expect*()
void	setTimeout(long time, TimeUnit unit)	Set the timeout that the expector should assume for each call to expect*()

Methods inherited from class java.lang.Object

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

Constructor Detail

Expecter

public Expecter(Dequeuer stream)

Constructor

Parameters:

stream - Associate expecter with this stream

Expecter

public Expecter(Dequeuer stream,
                TupleComparator comparator)

Constructor

Parameters:

stream - Associate expecter with this stream

comparator - Comparator to use

Method Detail

setTimeout

public void setTimeout(long time,
                       TimeUnit unit)

Set the timeout that the expector should assume for each call to expect*()

Parameters:

time - Time value

unit - Time units

getTimeout

public long getTimeout(TimeUnit unit)

get the timeout that the expector will use for each call to expect*()

Parameters:

unit - the unit in which to return the result.

Returns:

Timeout value in specified units

expect

public void expect(Expecter.DequeueSetting mode,
                   Tuple expected)
            throws StreamBaseException

Expect a given tuple from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the next tuple to match exactly

expected - the tuple to expect

Throws:

StreamBaseException - if expected match does not arrive

expectPredicate

public void expectPredicate(Expecter.DequeueSetting mode,
                            Expecter.Predicate p)
                     throws StreamBaseException

Expect a tuple that fulfills the given predicate from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the next tuple to match the predicate

p - the predicate

Throws:

StreamBaseException - if expected match does not arrive

expect

public void expect(Tuple tuple)
            throws StreamBaseException

Expect a tuple from the dequeuer. Equivalent to expect(DequeueSetting.DISALLOW_EXTRA_TUPLES, tuple);

Parameters:

tuple - Expected tuple

Throws:

StreamBaseException - if the next dequeued tuple does not match the expected tuple.

expect

public void expect(Expecter.DequeueSetting mode,
                   List<Tuple> expected)
            throws StreamBaseException

Expect multiple tuples in a particular order from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

expected - the tuples to expect

Throws:

StreamBaseException - if the next dequeued tuple does not match the expected tuple.

expectPredicate

public void expectPredicate(Expecter.DequeueSetting mode,
                            List<Expecter.Predicate> expected)
                     throws StreamBaseException

Expect a number of tuples, each fulfilling one predicate in a list, from the Dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

expected - the predicates we expect the dequeued tuples to fulfill

Throws:

StreamBaseException - if the expected tuples do not arrive

expect

public void expect(List<Tuple> expected)
            throws StreamBaseException

Expect multiple tuples in a particular order from the dequeuer. Equivalent to expect(DequeueSetting.DISALLOW_EXTRA_TUPLES, expected);

Parameters:

expected - List of expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expect

public void expect(Expecter.DequeueSetting mode,
                   Tuple... tuples)
            throws StreamBaseException

Expect multiple tuples in a particular order from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

tuples - Ordered expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expect

public void expect(Tuple... tuples)
            throws StreamBaseException

Expect multiple tuples in a particular order from the dequeuer. Equivalent to expect(DequeueSetting.DISALLOW_EXTRA_TUPLES, tuples);

Parameters:

tuples - Ordered expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expect

public <T> void expect(Expecter.DequeueSetting mode,
                       TupleMaker<T> tupleMaker,
                       T t)
                throws StreamBaseException

Expect a tuple from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

tupleMaker - Tuple factory

t - Tuple to expect

Throws:

StreamBaseException - if the next dequeued tuple does not match the expected tuple.

expect

public <T> void expect(TupleMaker<T> tupleMaker,
                       T t)
                throws StreamBaseException

Expect a tuple from the dequeuer. Equivalent to expect(DequeueSetting.DISALLOW_EXTRA_TUPLES, tupleMaker, t);

Parameters:

tupleMaker - Tuple factory

t - Tuple to expect

Throws:

StreamBaseException - if the next dequeued tuple does not match the expected tuple.

expect

public <T> void expect(Expecter.DequeueSetting mode,
                       TupleMaker<T> tupleMaker,
                       T... t)
                throws StreamBaseException

Expect a tuple from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

tupleMaker - Tuple factory

t - Ordered list of expected tuples

Throws:

StreamBaseException - if the next dequeued tuple does not match the expected tuple.

expect

public <T> void expect(TupleMaker<T> tupleMaker,
                       T... t)
                throws StreamBaseException

Expect multiple tuples in a particular order from the dequeuer. Equivalent to expect(DequeueSetting.DISALLOW_EXTRA_TUPLES, tupleMaker, t);

Parameters:

tupleMaker - Tuple factory

t - Ordered list of expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expect

public <T> void expect(Expecter.DequeueSetting mode,
                       TupleMaker<T> tupleMaker,
                       List<T> t)
                throws StreamBaseException

Expect a tuple from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

tupleMaker - Tuple factory

t - List of expected tuples

Throws:

StreamBaseException - if the next dequeued tuple does not match the expected tuple.

expect

public <T> void expect(TupleMaker<T> tupleMaker,
                       List<T> t)
                throws StreamBaseException

Expect multiple tuples in a particular order from the dequeuer. Equivalent to expect(DequeueSetting.DISALLOW_EXTRA_TUPLES, tupleMaker, t);

Parameters:

tupleMaker - Tuple factory

t - List of expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnordered

public void expectUnordered(Expecter.DequeueSetting mode,
                            List<Tuple> expected)
                     throws StreamBaseException

Expect multiple tuples in any order from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

expected - the expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnorderedPredicate

public void expectUnorderedPredicate(Expecter.DequeueSetting mode,
                                     List<Expecter.Predicate> expected)
                              throws StreamBaseException

Expect tuples that fulfill multiple predicates in any order from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

expected - the predicates incoming tuples are expected to match

Throws:

StreamBaseException - if the dequeued tuples do not match the expected predicates.

expectUnordered

public void expectUnordered(List<Tuple> expected)
                     throws StreamBaseException

Expect multiple tuples in any order from the dequeuer. Equivalent to expectUnordered(DequeueSetting.DISALLOW_EXTRA_TUPLES, expected);

Parameters:

expected - List of expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnordered

public void expectUnordered(Expecter.DequeueSetting mode,
                            Tuple... expected)
                     throws StreamBaseException

Expect multiple tuples in any order from the dequeuer

Parameters:

mode - whether to allow extra tuples or require the tuples to match without intermediate tuples

expected - the expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnordered

public void expectUnordered(Tuple... expected)
                     throws StreamBaseException

Expect multiple tuples in any order from the dequeuer. Equivalent to expectUnordered(DequeueSetting.DISALLOW_EXTRA_TUPLES, expected);

Parameters:

expected - Ordered list of expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnordered

public <T> void expectUnordered(Expecter.DequeueSetting mode,
                                TupleMaker<T> tupleMaker,
                                T... t)
                         throws StreamBaseException

Expect multiple tuples in any order from the dequeuer

Parameters:

mode - Dequeue mode

tupleMaker - Tuple factory

t - Expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnordered

public <T> void expectUnordered(TupleMaker<T> tupleMaker,
                                T... t)
                         throws StreamBaseException

Expect multiple tuples in any order from the dequeuer. Equivalent to expectUnordered(DequeueSetting.DISALLOW_EXTRA_TUPLES, tupleMaker, t);

Parameters:

tupleMaker - Tuple factory

t - Expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnordered

public <T> void expectUnordered(Expecter.DequeueSetting mode,
                                TupleMaker<T> tupleMaker,
                                List<T> t)
                         throws StreamBaseException

Expect multiple tuples in any order from the dequeuer

Parameters:

mode - Dequeue mode

tupleMaker - Tuple factory

t - List of expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectUnordered

public <T> void expectUnordered(TupleMaker<T> tupleMaker,
                                List<T> t)
                         throws StreamBaseException

Expect multiple tuples in any order from the dequeuer. Equivalent to expectUnordered(DequeueSetting.DISALLOW_EXTRA_TUPLES, tupleMaker, t);

Parameters:

tupleMaker - Tuple factory

t - Expected tuples

Throws:

StreamBaseException - if the dequeued tuples do not match the expected tuples.

expectNothing

public void expectNothing(long time,
                          TimeUnit unit)
                   throws StreamBaseException

Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.

Parameters:

time - the period of time to dequeue for (must be ≥ 0)

unit - the unit for time

Throws:

StreamBaseException - Error detected

expectNothing

public void expectNothing()
                   throws StreamBaseException

Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.

Throws:

StreamBaseException - Error detected