core/realtime/realtime.service.ts
A wrapper class for handling realtime notifications in RxJS fashion.
Methods |
|
Accessors |
constructor(realtimeSubject: RealtimeSubjectService)
|
||||||
Parameters :
|
Protected Abstract 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
|
active |
getactive()
|
A flag displaying if realtime notifications are currently active.
Returns :
boolean
|