Properties
connected
connected: boolean
connecting
connecting: boolean
exchanges
exchanges: any[]
grpcStream
grpcStream: any
lastheartbeat
lastheartbeat: Date
lastheartbeatsec
lastheartbeatsec: string
lastheartbeatstr
lastheartbeatstr: string
remoteip
remoteip: string
signedin
signedin: boolean
Methods
Close
- Close(): void
-
Returns void
Initialize
- Initialize(ws: any, stream: any, call: any, req: any): Promise<boolean>
-
Parameters
-
ws: any
-
stream: any
-
call: any
-
req: any
Returns Promise<boolean>
SendWatch
- SendWatch(watch: any, next: any, span: any): void
-
Parameters
-
watch: any
-
next: any
-
span: any
Returns void
UnWatch
- UnWatch(id: string, jwt: string): Promise<void>
-
Returns Promise<void>
Watch
- Watch(aggregates: object[], collectionname: string, jwt: string): Promise<string>
-
Parameters
-
aggregates: object[]
-
collectionname: string
-
jwt: string
Returns Promise<string>
onConnected
- onConnected(client: client): void
-
Returns void
onDisconnected
- onDisconnected(client: client, error: Error): void
-
Returns void
ping
- ping(span: any): void
-
Returns void
queuecount
- queuecount(): number
-
Returns number