core/realtime/operation-bulk-realtime.service.ts
A service for handling bulk operation realtime notifications in RxJS fashion.
Methods |
|
constructor(realtimeSubject: RealtimeSubjectService)
|
||||||
|
Parameters :
|
| Protected channel |
channel()
|
|
Returns :
string
|
| onCreate$ |
onCreate$()
|
|
Get an Observable of all CREATE realtime notifications.
Returns :
Observable<IOperationBulk>
An [[Observable]] of newly created entity objects. |
| Protected getChannel | ||||||
getChannel(entityOrId?: string | number | IIdentified)
|
||||||
|
Parameters :
Returns :
any
|
| Protected getIdString | ||||||
getIdString(reference: number | string | IIdentified)
|
||||||
|
Parameters :
Returns :
string
|
| onAll$ | ||||||||
onAll$(entityOrId?: string | number | IIdentified)
|
||||||||
|
Get an Observable of all realtime notifications.
Parameters :
Returns :
Observable<RealtimeMessage<T>>
An [[Observable]] of notifications wrapped as [[RealtimeMessage]] |
| onUpdate$ | ||||||||
onUpdate$(entityOrId?: string | number | IIdentified)
|
||||||||
|
Get an Observable of all UPDATE realtime notifications.
Parameters :
Returns :
Observable<T>
An [[Observable]] of updated entity objects. |
| start |
start()
|
|
Subscribes again all realtime channels with active observers.
Returns :
void
|
| stop |
stop()
|
|
Stops realtime notifications and unsubscribes all realtime channels.
Returns :
void
|