mirror of
https://github.com/xibyte/jsketcher
synced 2025-12-06 16:33:15 +01:00
19 lines
394 B
JavaScript
19 lines
394 B
JavaScript
import {StreamBase} from './base';
|
|
|
|
export class ScanStream extends StreamBase {
|
|
|
|
constructor(stream, seed, scanFunc) {
|
|
super();
|
|
this.stream = stream;
|
|
this.value = seed;
|
|
this.scanFunc = scanFunc;
|
|
}
|
|
|
|
attach(observer) {
|
|
observer(this.value);
|
|
return this.stream.attach(v => {
|
|
this.value = this.scanFunc(this.value, v);
|
|
observer(this.value);
|
|
});
|
|
}
|
|
}
|