Added a definition of zipSinks using concurrency