ChanArray, Distributor, Collector (Topology)

Import: from stbass import ChanArray, Distributor, Collector Also: from stbass.topology import ChanArray, Distributor, Collector

ChanArray

An indexed array of identically-typed channels:

arr = ChanArray(int, 5, name_prefix="worker")