| 25808 | // It seems a linked list but it is not |
| 25809 | // there will be only 2 of these for each stream |
| 25810 | function CorkedRequest(state) { |
| 25811 | var _this = this; |
| 25812 | |
| 25813 | this.next = null; |
| 25814 | this.entry = null; |
| 25815 | this.finish = function (err) { |
| 25816 | var entry = _this.entry; |
| 25817 | _this.entry = null; |
| 25818 | while (entry) { |
| 25819 | var cb = entry.callback; |
| 25820 | state.pendingcb--; |
| 25821 | cb(err); |
| 25822 | entry = entry.next; |
| 25823 | } |
| 25824 | if (state.corkedRequestsFree) { |
| 25825 | state.corkedRequestsFree.next = _this; |
| 25826 | } else { |
| 25827 | state.corkedRequestsFree = _this; |
| 25828 | } |
| 25829 | }; |
| 25830 | } |
| 25831 | }).call(this,require('_process')) |
| 25832 | },{"./_stream_duplex":140,"_process":138,"buffer":77,"buffer-shims":76,"core-util-is":78,"events":79,"inherits":81,"process-nextick-args":137,"util-deprecate":154}],145:[function(require,module,exports){ |
| 25833 | 'use strict'; |