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 and Description
static class	Expecter.AbstractPredicate Subclass this and override isExpected(Tuple t) to simplify creating predicates.
static class	Expecter.DequeueSetting
static interface	Expecter.Predicate To expect tuples by predicate, implement this interface.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	expect(Expecter.DequeueSetting mode, List<Tuple> expected) Expect multiple tuples in a particular order from the dequeuer
void	expect(Expecter.DequeueSetting mode, 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
<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(List<Tuple> expected) Expect multiple tuples in a particular order from the dequeuer.
void	expect(Tuple... tuples) Expect multiple tuples in a particular order from the dequeuer.
void	expect(Tuple tuple) Expect a tuple 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 multiple tuples in a particular order from the dequeuer.
<T> void	expect(TupleMaker<T> tupleMaker, T t) Expect a tuple 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(Expecter.DequeueSetting mode, List<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(List<Tuple> expected) Expect multiple tuples in any order from the dequeuer.
void	expectUnordered(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	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)

Expecter

public Expecter(Dequeuer stream,
                TupleComparator comparator)

Method Detail

setTimeout

public void setTimeout(long time,
                       TimeUnit unit)

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

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.

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);

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);

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

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);

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

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);

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

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);

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

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);

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);

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);

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

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);

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

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);

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

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