WatcherContext

def __init__(
    self,
    watcher: BaseWatcher,
    message: Union[SyncStreamMessage[MsgType], StreamMessage[MsgType]],
    **extra_ack_args: Any,
):
    """Initialize a new instance of the class.

    Args:
        watcher: An instance of BaseWatcher.
        message: An instance of SyncStreamMessage or StreamMessage.
        **extra_ack_args: Additional arguments for acknowledgement.

    Attributes:
        watcher: An instance of BaseWatcher.
        message: An instance of SyncStreamMessage or StreamMessage.
        extra_ack_args: Additional arguments for acknowledgement.
    !!! note

        The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
    """
    self.watcher = watcher
    self.message = message
    self.extra_ack_args = extra_ack_args or {}