This package holds classes representing operators and channels necessary for full dataflow concurrency.