1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
| import { createOperatorSubscriber } from './OperatorSubscriber';
| export function scanInternals(accumulator, seed, hasSeed, emitOnNext, emitBeforeComplete) {
| return function (source, subscriber) {
| var hasState = hasSeed;
| var state = seed;
| var index = 0;
| source.subscribe(createOperatorSubscriber(subscriber, function (value) {
| var i = index++;
| state = hasState
| ?
| accumulator(state, value, i)
| :
| ((hasState = true), value);
| emitOnNext && subscriber.next(state);
| }, emitBeforeComplete &&
| (function () {
| hasState && subscriber.next(state);
| subscriber.complete();
| })));
| };
| }
| //# sourceMappingURL=scanInternals.js.map
|
|
