heat-sdk
Options
All
Public
Public/Protected
All
Inherited
Externals
Only exported
Menu
Subscriber
Base
constructor
RETRY_
SYNC_
DELAY
connected
Socket
Promise
subscribe
Topics
unsubscribe
Topics
url
create
Unsubscribe
Function
find
Existing
OrAdd
New
Topic
get
Connected
Socket
invoke
OnDisconnect
Listeners
invoke
OnMessage
Listeners
invoke
OnReconnect
Listeners
on
Message
Received
send
Subscribe
send
Unsubscribe
subscribe
sync
Topic
Subscriptions
topic
Matches
Details
unsubscribe
Topic
Hierarchy
SubscriberBase
HeatSubscriber
Index
Constructors
constructor
Properties
RETRY_
SYNC_
DELAY
connected
Socket
Promise
subscribe
Topics
unsubscribe
Topics
url
Methods
create
Unsubscribe
Function
find
Existing
OrAdd
New
Topic
get
Connected
Socket
invoke
OnDisconnect
Listeners
invoke
OnMessage
Listeners
invoke
OnReconnect
Listeners
on
Message
Received
send
Subscribe
send
Unsubscribe
subscribe
sync
Topic
Subscriptions
topic
Matches
Details
unsubscribe
Topic
Constructors
constructor
new
Subscriber
Base
(
url
:
string
)
:
SubscriberBase
Parameters
url:
string
Returns
SubscriberBase
Properties
Private
RETRY_
SYNC_
DELAY
RETRY_
SYNC_
DELAY
:
number
= 2.5 * 1000
Private
connected
Socket
Promise
connected
Socket
Promise
:
Promise
<
any
>
= null
Private
subscribe
Topics
subscribe
Topics
:
Array
<
SubscriberTopic
<
any
>
>
= []
Private
unsubscribe
Topics
unsubscribe
Topics
:
Array
<
SubscriberTopic
<
any
>
>
= []
Private
url
url
:
string
Methods
Private
create
Unsubscribe
Function
create
Unsubscribe
Function
(
topic
:
SubscriberTopic
<
any
>
, subscription
:
Subscription
<
any
>
)
:
function
Parameters
topic:
SubscriberTopic
<
any
>
subscription:
Subscription
<
any
>
Returns
function
(
)
:
void
Returns
void
Private
find
Existing
OrAdd
New
Topic
find
Existing
OrAdd
New
Topic
(
topic
:
SubscriberTopic
<
any
>
)
:
SubscriberTopic
<
any
>
Parameters
topic:
SubscriberTopic
<
any
>
Returns
SubscriberTopic
<
any
>
Private
get
Connected
Socket
get
Connected
Socket
(
)
:
Promise
<
any
>
Returns
Promise
<
any
>
Private
invoke
OnDisconnect
Listeners
invoke
OnDisconnect
Listeners
(
topic
:
SubscriberTopic
<
any
>
)
:
void
Parameters
topic:
SubscriberTopic
<
any
>
Returns
void
Private
invoke
OnMessage
Listeners
invoke
OnMessage
Listeners
(
topic
:
SubscriberTopic
<
any
>
, contents
:
Object
)
:
void
Parameters
topic:
SubscriberTopic
<
any
>
contents:
Object
Returns
void
Private
invoke
OnReconnect
Listeners
invoke
OnReconnect
Listeners
(
topic
:
SubscriberTopic
<
any
>
)
:
void
Parameters
topic:
SubscriberTopic
<
any
>
Returns
void
Private
on
Message
Received
on
Message
Received
(
messageJson
:
Object
)
:
void
Parameters
messageJson:
Object
Returns
void
Private
send
Subscribe
send
Subscribe
(
websocket
:
WebSocket
, topic
:
SubscriberTopic
<
any
>
)
:
void
Parameters
websocket:
WebSocket
topic:
SubscriberTopic
<
any
>
Returns
void
Private
send
Unsubscribe
send
Unsubscribe
(
websocket
:
WebSocket
, topic
:
SubscriberTopic
<
any
>
)
:
void
Parameters
websocket:
WebSocket
topic:
SubscriberTopic
<
any
>
Returns
void
Protected
subscribe
subscribe<T>
(
newTopic
:
SubscriberTopic
<
any
>
)
:
Subscription
<
T
>
Type parameters
T
Parameters
newTopic:
SubscriberTopic
<
any
>
Returns
Subscription
<
T
>
Private
sync
Topic
Subscriptions
sync
Topic
Subscriptions
(
)
:
void
Returns
void
Private
topic
Matches
Details
topic
Matches
Details
(
topic
:
SubscriberTopic
<
any
>
, details
:
object
)
:
boolean
Parameters
topic:
SubscriberTopic
<
any
>
details:
object
[
key:
string
]:
any
Returns
boolean
Private
unsubscribe
Topic
unsubscribe
Topic
(
topic
:
SubscriberTopic
<
any
>
)
:
void
Parameters
topic:
SubscriberTopic
<
any
>
Returns
void
Generated using
TypeDoc