Providers
SocketSubscriber
A SocketSubscriber uses a socket transport to handle events and should use
_emit to manage the events.
Creates a new SocketSubscriber attached to
The filter.
Sub-classes must override this to emit the events on the provider.
Pause the subscriber.
Resume the subscriber.
Start the subscriber.
Stop the subscriber.
- A sub-class MUST call the
_start()method once connected - A sub-class MUST override the
_write(string)method - A sub-class MUST call
_processMessage(string)for each message
Extended by
Implements
Constructors
new SocketSubscriber()
provider listening to filter.
Parameters
| Parameter | Type | Description |
|---|---|---|
provider | SocketProvider | The socket provider. |
filter | any[] | The filter. |
zone | Zone | - |
Returns
SocketSubscriber
Source
providers/provider-socket.ts:63Accessors
filter
Returns
any[]
Source
providers/provider-socket.ts:46Methods
_emit()
Parameters
| Parameter | Type | Description |
|---|---|---|
provider | SocketProvider | The socket provider. |
message | any | The message to emit. |
Returns
Promise<void>
Abstract
Source
providers/provider-socket.ts:151pause()
Parameters
| Parameter | Type | Description |
|---|---|---|
dropWhilePaused? | boolean | Whether to drop logs while paused. |
Returns
void
Implementation of
Subscriber.pause
Source
providers/provider-socket.ts:98resume()
Returns
void
Implementation of
Subscriber.resume
Source
providers/provider-socket.ts:111start()
Returns
void
Implementation of
Subscriber.start
Source
providers/provider-socket.ts:76stop()
Returns
void
Implementation of
Subscriber.stop