Refactored the tests
More cleanups
Fixed `drop`. Added `flatMap`. More tests.
Add require()s and convenience methods
Fix MergerMachine logic, it was completely broken
Optimize: don't use `for`
Fix: correctly construct onComplete
Add convenience methods
Add tests for Connectors