forced_sampler.py 文件源码

def process(self, message) -> Iterable:
        stream = str(message)

        if stream not in self._streams:
            self._streams.add(stream)

            for bind in combinations(self._streams, self._power):
                if stream in bind:
                    self._sampler.bind(sorted(bind), self._joiner)

        yield from self._sampler.process(message)