Added channel future listener for channel write. Added concurrency tests.