I'm encountering an issue that I believe stems from my limited understanding of Observables.
This project is built on Angular2 (v4.0.3) and employs rx/js along with Observables.
Within a state service, there exists a store for events:
// Observable string sources
private currentEventStore = new BehaviorSubject<string>("");
// Observable string streams
public currentEvent$ = this.currentEventStore.asObservable();
// Service message commands
setCurrentEvent(nextEvent: string) {
this.currentEventStore.next(nextEvent);
}
In my components, I subscribe to currentEvent$ to listen for events and act accordingly.
this.stateSvc.currentEvent$
.subscribe(
currentEvent => {
this.currentEvent = currentEvent;
if (currentEvent != '') {
this.handleCurrentEvent(currentEvent);
}
});
The issue arises when the store accumulates all events and returns them each time. So, upon triggering a 'create' event, my function creates a record - which works fine initially. However, with subsequent 'create' events, the function picks up multiple events, leading to multiple records being created. This pattern continues with each successive event.
My goal is to have the stream flush out old events so that the currentEvent$ store only retains unaddressed events.
Is there a way to flush the store? Am I overlooking something in my expectations and implementation?