multi-channel filter for partitioning data streams on wot.io