Add bus/collect and tests for threads and channels.