_start()
method once connected_write(string)
method_processMessage(string)
for each messageprovider
listening to filter
.
Parameter | Type | Description |
---|---|---|
provider | SocketProvider | The socket provider. |
filter | any [] | The filter. |
zone | Zone | - |
SocketSubscriber
any
[]
Parameter | Type | Description |
---|---|---|
provider | SocketProvider | The socket provider. |
message | any | The message to emit. |
Promise
<void
>
Parameter | Type | Description |
---|---|---|
dropWhilePaused ? | boolean | Whether to drop logs while paused. |
void
Subscriber
.pause
void
Subscriber
.resume
void
Subscriber
.start
void
Subscriber
.stop