pipelined/pipe

Graceful cancellation support

Closed this issue · 1 comments

dudk commented

Currently pipe execution can be cancelled with close method, but it doesn't affect components which use goroutines internally i.e. mixer.

New interface is provided to support graceful cancellation: Interrupter.

Interrupt method will be called if pipe execution was stopped by Close() call.

dudk commented

Implemented in #14