# -*- coding: utf-8 -*-
import json
from typing import Any, Dict

from . import BaseConsumer


class StdoutConsumer(BaseConsumer):
    def __init__(self, settings: Dict[str, Any]) -> None:
        super().__init__(settings)

    def poll(self):
        return super().poll()

    def write(self, data: Dict[str, Any]):
        print(json.dumps(data))