rajatkb/Conference-Notify

[Feat.] add new stream filters like 'update'/'create'/'replace' etc for ConferenceStream

Closed this issue · 0 comments

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.