core/realtime/operation-realtime.service.ts
A service for handling bulk operation realtime notifications in RxJS fashion.
Methods |
|
constructor(realtimeSubject: RealtimeSubjectService)
|
||||||
|
Parameters :
|
| Protected channel |
channel()
|
|
Returns :
string
|
| 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]] |
| onDelete$ | ||||||||
onDelete$(entityOrId?: string | number | IIdentified)
|
||||||||
|
Get an Observable of all DELETE realtime notifications.
Parameters :
Returns :
Observable<number>
An [[Observable]] of deleted entity objects. |
| 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
|