Source code for nqs_sdk.interfaces.observable_consumer

from abc import ABC, abstractmethod
from typing import List, Optional, Tuple

from nqs_sdk.nqs_sdk import MetricName, SealedParameters, SimulationClock




[docs]
class ObservableConsumer(ABC):


[docs]
    @abstractmethod
    def initialize(self, parameters: SealedParameters) -> None: ...





[docs]
    @abstractmethod
    def consume(


        self, parameters: SealedParameters, clock: SimulationClock
    ) -> Tuple[List[MetricName], Optional[int]]: ...