faust.livecheck.signals

LiveCheck Signals - Test communication and synchronization.

class faust.livecheck.signals.BaseSignal(name: str = '', case: faust.livecheck.signals._Case = None, index: int = -1) → None[source]

Generic base class for signals.

clone(**kwargs) → faust.livecheck.signals.BaseSignal[source]

Clone this signal using keyword arguments.

Return type

BaseSignal[~VT]

class faust.livecheck.signals.Signal(name: str = '', case: faust.livecheck.signals._Case = None, index: int = -1) → None[source]

Signal for test case using Kafka.

Used to wait for something to happen elsewhere.