1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
/**
* Copyright 2013-present, Facebook, Inc.
* All rights reserved.
*
* This source code is licensed under the BSD-style license found in the
* LICENSE file in the root directory of this source tree. An additional grant
* of patent rights can be found in the PATENTS file in the same directory.
*
*
*/
'use strict';
var _assign = require('object-assign');
exports.createUpdateQueue = function (partialState) {
var queue = {
partialState: partialState,
callback: null,
callbackWasCalled: false,
next: null,
isReplace: false,
isForced: false,
tail: null
};
queue.tail = queue;
return queue;
};
exports.addToQueue = function (queue, partialState) {
var node = {
partialState: partialState,
callback: null,
callbackWasCalled: false,
next: null
};
queue.tail.next = node;
queue.tail = node;
return queue;
};
exports.addCallbackToQueue = function (queue, callback) {
if (queue.tail.callback) {
// If the tail already as a callback, add an empty node to queue
exports.addToQueue(queue, null);
}
queue.tail.callback = callback;
return queue;
};
exports.callCallbacks = function (queue, context) {
var node = queue;
while (node) {
if (node.callback && !node.callbackWasCalled) {
node.callbackWasCalled = true;
node.callback.call(context);
}
node = node.next;
}
};
exports.mergeUpdateQueue = function (queue, prevState, props) {
var node = queue;
var state = queue.isReplace ? null : _assign({}, prevState);
while (node) {
var _partialState = void 0;
if (typeof node.partialState === 'function') {
var updateFn = node.partialState;
_partialState = updateFn(state, props);
} else {
_partialState = node.partialState;
}
state = _assign(state || {}, _partialState);
node = node.next;
}
return state;
};
|
