faust.livecheck.signals¶
LiveCheck Signals - Test communication and synchronization.
- class faust.livecheck.signals.BaseSignal(name: str = '', case: Optional[_Case] = None, index: int = -1)[source]¶
Generic base class for signals.
- case: _Case¶
- async send(value: Optional[VT] = None, *, key: Optional[Any] = None, force: bool = False) None[source]¶
Notify test that this signal is now complete.
- Return type:
None
- async wait(*, key: Optional[Any] = None, timeout: Optional[Union[timedelta, float, str]] = None) VT[source]¶
Wait for signal to be completed.
- Return type:
~VT
- async resolve(key: Any, event: SignalEvent) None[source]¶
Resolve signal with value.
- Return type:
None
- clone(**kwargs: Any) BaseSignal[source]¶
Clone this signal using keyword arguments.
- Return type:
- class faust.livecheck.signals.Signal(name: str = '', case: Optional[_Case] = None, index: int = -1)[source]¶
Signal for test case using Kafka.
Used to wait for something to happen elsewhere.
