from abc import ABC, abstractmethod


class PublicFeedReaderABC(ABC):

    @abstractmethod
    async def route_message(self, msg):
        """route message to appropriate method to publish
        one of coros :
            - publish_heartbeat
            - publish_system_status
            - publish_subscription_status
            - publish_data

        To be implemented by ExchangeFeedReader
        """
        raise NotImplementedError

9f20647d1eb9151dbccfd25be9f42a1d26f25182
<mask token>

<mask token>


class PublicFeedReaderABC(ABC):

    @abstractmethod
    async def route_message(self, msg):
        """route message to appropriate method to publish
        one of coros :
            - publish_heartbeat
            - publish_system_status
            - publish_subscription_status
            - publish_data

        To be implemented by ExchangeFeedReader
        """
        raise NotImplementedError

from abc import ABC, abstractmethod


class PublicFeedReaderABC(ABC):

    @abstractmethod
    async def route_message(self, msg):
        """route message to appropriate method to publish
        one of coros :
            - publish_heartbeat
            - publish_system_status
            - publish_subscription_status
            - publish_data

        To be implemented by ExchangeFeedReader
        """
        raise NotImplementedError
