#include <WaitForQBox.h>
Inherits QBox.
Protected Member Functions | |
void | setupImpl () throw (AuroraException) |
void | initImpl () throw (AuroraException) |
void | runImpl (QBoxInvocation &) throw (AuroraException) |
AURORA_DECLARE_QBOX (WaitForQBox,"waitfor") |
|
|
|
Reimplemented from QBox.
|
|
Tuples from stream 0 are simply buffered Then, for every tuple on stream 1, _predicate is applied to it and each of the tuples in the buffer. Emit the buffered tuple if _predicate is true Reimplemented from QBox.
|
|
Implements QBox.
|