[Feat.] add new stream filters like 'update'/'create'/'replace' etc for ConferenceStream
Closed this issue · 0 comments
rajatkb commented
Is your feature request related to a problem? Please describe.
The current project already has changeStream observer setup against mongo collection. but the getStream() is a standard observer that emits all events. We want a few custom functions like getUpdateStream() , getInsertStream() etc to detect these individual events to attach listeners to,
Describe the solution you'd like
Implement
- getInsertStream():Observable
- getUpdateStream():Observable
- getDeleteStream():Observable
in src/interfaces/service/stream/conferenceStream and src/service/stream/conferenceStream
Additional context
Rxjs is already included in the environment so make sure to use that, for filter and map operation over the observables.