Promise/A
定义
- Promise操作只会处于3中状态的一种:未完成状态、完成状态、失败态
- Promise的状态只会出现在从未完成状态向完成状态或失败态的转化,不能逆反。完成态和失败态不能互相转化
- Promise的状态一旦转化,将不能逆转。
在api定义上,Promise/A中一个promise 对象只要具备then()方法即可。对then()方法的简单要去如下:
- 接受完成态、错误态的回调方法。在操作完成或错误时触发对应的方法。
- 可选的progress事件回调作为第三个方法
- then()方法只接受function对象
- then()方法继续返回Promise对象,以实现链式调用。
定义如下:
then(fulfilledHandler, errorHandler, progressHandler)
演示
通过继承Node 的events模块来完成演示
// Promise
var Promise = function () {
EventEmitter.call(this)
}
utils.inherits(Promise, EventEmitter)
Promise.prototype.then = function (fulfilledHandler, errorHandler, progressHandler) {
if (typeof fulfilledHandler === 'function') {
this.once('success', fulfilledHandler)
}
if (typeof errorHandler === 'function') {
this.once('error', errorHandler)
}
if (typeof progressHandler === 'function') {
this.once('progress', progressHandler)
}
return this;
}
// Deferred
var Deferred = function () {
this.state = 'unfulfilled'
this.promise = new Promise;
}
Deferred.prototype.resolve = function (obj) {
this.state = 'fulfilled'
this.promise.emit('success', obj)
}
Deferred.prototype.reject = function (obj) {
this.state = 'failed'
this.promise.emit('error', obj)
}
Deferred.prototype.progress = function (obj) {
this.promise.emit('progress', obj)
}
// 对如下的相应对象进行封装
// 未经Promise封装
res.on('data', function (chunk){
console.log(chunk)
})
res.on('end', function () {
// Done
})
res.on('error', function () {
// Error
})
// 封装过程
var promisify = function (res) {
var deferred = new Deferred()
var result = ''
res.on('data', function (chunk) {
result += chunk
deferred.progress(chunk)
})
res.on('end', function() {
deferred.resolve(result)
})
res.on('error', function (err) {
deferred.reject(err)
})
return deferred.promise
}
// 经Promise封装
promisify(res).then(function () {
// Done
}, function () {
// Error
}, function (chunk) {
console.log(chunk)
})