pubsubtk.processor.processor_base¶

pubsubtk.processor.processor_base ¶

ビジネスロジックを担う Processor 用の抽象基底クラス。

ProcessorBase ¶

ProcessorBase(store: Store[TState], *args, **kwargs)

Bases: PubSubDefaultTopicBase, Generic[TState]

Processor の基底クラス。

Store を受け取って初期化します。

Source code in src/pubsubtk/processor/processor_base.py

def __init__(self, store: Store[TState], *args, **kwargs) -> None:
    """Store を受け取って初期化します。"""

    # 型引数付きの Store[TState] を取得
    self.store: Store[TState] = store

    super().__init__(*args, **kwargs)