var co = require('gocsp-co')
var thunk = require('gocsp-thunk')

co(function* (x, y) {

    // yield promise
    yield new Promise((resolve, reject) => {
        resolve('hi')
    })

    // yield thunk
    yield thunk(done => {
        done()
    })

    // yield callback
    yield done => {
        done()
    }

    return x + y

// !!! caution: unlike tj's co, callback is NOT last argument
})(1, 2)(function (err, val) {
    assert(val === 3)
})

function asyncFunction(arg0, arg1, arg2) {
    return new Promise(co.spawn(function* () {
        // ...
        // ...
    }))
}

co(function* (x, y) {
    return x + y
})(1, 2)(function (err, val) {
    assert(val === 3)
})

// with a generator
co.spawn(function* (x, y) {
    return x + y
}(1, 2))(function (err, val) {
    assert(val === 3)
})

// with a generator function
var x = 1, y = 2
co.spawn(function* () {
    return x + y
})(function (err, val) {
    assert(val === 3)
})

co.spawn(function* () {
    // read max 10 files at the same time
    var read = co.limit(10, function* (filename) {
        return yield thunk.ify(fs.readFile)(filename)
    })
    var files = yield ['file1', 'file2', 'etc...'].map(read)
})

// gocsp-each
each(chan, co.limit(10, function* (data) {
    // ...
}))

// limit total number of connection
http.createServer(co.limit(1000, function* (req, res) {
    // ...
}))