Добавить прослушку ctx.done и закрывать каналы на чтение / запись когда ctx.done 

во все Run добавить контекст
и слушать его на вызов метода Close