const fs = require('fs')
const pipe = require('co-pipe')
 
const reader = fs.createReadStream('foo.txt')
const writer = fs.createWriteStream('bar.txt')
 
pipe(reader, writer).then(
  () => console.log('File successfully copied.'),
  (error) => console.log(`Something was wrong with ${
    error.stream === reader ? 'reader' : 'writer'
  }`)
)

const fs = require('fs')
const co = require('co')
const pipe = require('co-pipe')
 
co(function * () {
  const reader = fs.createReadStream('foo.txt')
  const writer = fs.createWriteStream('bar.txt')
 
  try {
    yield pipe(reader, writer)
    console.log('File successfully copied.')
  } catch (error) {
    console.log(`Something was wrong with ${
      error.stream === reader ? 'reader' : 'writer'
    }`)
  }
})

const fs = require('fs')
const koa = require('koa')
const pipe = require('co-pipe')
 
const app = koa()
 
app.use(function * () {
  const writer = fs.createWriteStream('foo.txt')
  yield pipe(this.req, writer)
  this.body = 'Request successfully written to foo.txt'
})

const fs = require('fs')
const zlib = require('zlib')
const pipe = require('co-pipe')
 
const reader = fs.createReadStream('foo.txt')
const gzip = zlib.createGzip()
const writer = fs.createWriteStream('bar.txt.gz')
 
pipe(reader, gzip, writer).then(
  () => console.log('File successfully gzipped.'),
  (error) => console.log(`Something was wrong with ${
    error.stream === reader ? 'reader' :
      (error.stream === gzip ? 'gzip' : 'writer')
  }`)
)