Source code for sigfeat.base.sink
"""Implements the abstract Sink class."""
import abc
import six
[docs]@six.add_metaclass(abc.ABCMeta)
class Sink(object):
"""Sink base class."""
[docs] @abc.abstractclassmethod
def receive(self, datad):
"""Shall receive dictionaries directly written to source."""
pass # pragma: no coverage
[docs] @abc.abstractclassmethod
def receive_append(self, resultd):
"""Shall receive result dictionaries appending data to fields."""
pass # pragma: no coverage