scalaz/scalaz-stream — pull request #57 by pchlupacek (2013-12-04 07:32:00+00:00)
Title: Topic/receive y

Modified wye implementation to :
- Changed from These algebra to ReceiveY
- Allow wye to perform step when either side terminates
- Cleanup now `interrupts` the last step if wye terminates before L/R terminates , to perform cleanup on L/R side
- The correct cleanup order (awaiting for L/R being interrupted before cleanup will run on L/R) can be implemented once the https://github.com/scalaz/scalaz/issues/599 will be resolved

Added to Process:
- runStep

Added to Step
- various small helper functions on Step object

Modified added to wye
- wye.dynamic - now stops when L or R terminates early

Slightly enhanced async Queue :
- making sure that every callback is now called from within S() strategy
- Failed and Close message is now just `Close`

@pchiusano can you please take quick look before I will merge this?

Thanks

P.