Class FlowTester.TupleDequeueHandle

  • Enclosing class:
    FlowTester

    public final class FlowTester.TupleDequeueHandle
    extends Object

    A dequeue handle created by initTupleDequeue for use when the tester is dequeueing tuples.

    • Method Detail

      • dequeue

        public List<Tuple> dequeue​(int minTuples)
                            throws TCSRuntimeException

        Poll the handle, returning any tuples found. Max wait time is specified at handle create time.

        Parameters:
        minTuples - minimum tuples wanted
        Returns:
        list of dequeued tuples
        Throws:
        TCSRuntimeException - on dequeue failure