|
|
|
@ -1,6 +1,6 @@ |
|
|
|
|
import {Injectable} from "@angular/core"; |
|
|
|
|
import {Observable, Subject} from "rxjs"; |
|
|
|
|
import {buffer, debounceTime, filter, scan} from "rxjs/operators"; |
|
|
|
|
import {buffer, debounceTime, filter} from "rxjs/operators"; |
|
|
|
|
import {HalResource} from "core-app/modules/hal/resources/hal-resource"; |
|
|
|
|
import {ResourceChangesetCommit} from "core-app/modules/fields/edit/services/hal-resource-editing.service"; |
|
|
|
|
|
|
|
|
@ -45,8 +45,7 @@ export class HalEventsService { |
|
|
|
|
.events$ |
|
|
|
|
.pipe( |
|
|
|
|
filter((event:HalEvent) => event.resourceType === resourceType), |
|
|
|
|
buffer(this.events$.pipe(debounceTime(debounceTimeInMs))), |
|
|
|
|
scan((acc, curr) => acc.concat(curr)) |
|
|
|
|
buffer(this.events$.pipe(debounceTime(debounceTimeInMs))) |
|
|
|
|
); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|