Search
Preparing search index...
The search index is not available
ddes
Options
All
Public
Public/Protected
All
Inherited
Externals
Only exported
Menu
Packages
@ddes/event-streaming
EventSubscriber
Class EventSubscriber
Hierarchy
EventEmitter
EventSubscriber
Index
Constructors
constructor
Properties
max
Queue
Size
queue
socket
default
Max
Listeners
Methods
add
Listener
close
emit
event
Names
get
Max
Listeners
listener
Count
listeners
on
once
prepend
Listener
prepend
Once
Listener
raw
Listeners
remove
All
Listeners
remove
Listener
set
Max
Listeners
listener
Count
Constructors
constructor
new
Event
Subscriber
(
params
:
object
&
ClientOptions
)
:
EventSubscriber
Parameters
params:
object
&
ClientOptions
events
:
FilterSet
[]
Optional
max
Queue
Size
?:
undefined
|
number
ws
Url
:
string
Returns
EventSubscriber
Properties
max
Queue
Size
max
Queue
Size
:
number
= 1000
Private
queue
queue
:
any
[]
= []
Private
Optional
socket
socket
:
WebSocket
Static
default
Max
Listeners
default
Max
Listeners
:
number
Methods
add
Listener
add
Listener
(
event
:
string
|
symbol
, listener
:
function
)
:
this
Parameters
event:
string
|
symbol
listener:
function
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
this
close
close
(
)
:
undefined
|
void
Returns
undefined
|
void
emit
emit
(
event
:
string
|
symbol
,
...
args
:
any
[]
)
:
boolean
Parameters
event:
string
|
symbol
Rest
...
args:
any
[]
Returns
boolean
event
Names
event
Names
(
)
:
Array
<
string
|
symbol
>
Returns
Array
<
string
|
symbol
>
get
Max
Listeners
get
Max
Listeners
(
)
:
number
Returns
number
listener
Count
listener
Count
(
type
:
string
|
symbol
)
:
number
Parameters
type:
string
|
symbol
Returns
number
listeners
listeners
(
event
:
string
|
symbol
)
:
Function
[]
Parameters
event:
string
|
symbol
Returns
Function
[]
on
on
(
event
:
string
|
symbol
, listener
:
function
)
:
this
Parameters
event:
string
|
symbol
listener:
function
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
this
once
once
(
event
:
string
|
symbol
, listener
:
function
)
:
this
Parameters
event:
string
|
symbol
listener:
function
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
this
prepend
Listener
prepend
Listener
(
event
:
string
|
symbol
, listener
:
function
)
:
this
Parameters
event:
string
|
symbol
listener:
function
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
this
prepend
Once
Listener
prepend
Once
Listener
(
event
:
string
|
symbol
, listener
:
function
)
:
this
Parameters
event:
string
|
symbol
listener:
function
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
this
raw
Listeners
raw
Listeners
(
event
:
string
|
symbol
)
:
Function
[]
Parameters
event:
string
|
symbol
Returns
Function
[]
remove
All
Listeners
remove
All
Listeners
(
event
?:
string
|
symbol
)
:
this
Parameters
Optional
event:
string
|
symbol
Returns
this
remove
Listener
remove
Listener
(
event
:
string
|
symbol
, listener
:
function
)
:
this
Parameters
event:
string
|
symbol
listener:
function
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
this
set
Max
Listeners
set
Max
Listeners
(
n
:
number
)
:
this
Parameters
n:
number
Returns
this
Static
listener
Count
listener
Count
(
emitter
:
EventEmitter
, event
:
string
|
symbol
)
:
number
Parameters
emitter:
EventEmitter
event:
string
|
symbol
Returns
number
Packages
@ddes/aws-
lambda-
transformer
@ddes/aws-
store
@ddes/cli
@ddes/core
@ddes/event-
streaming
@ddes/store-
transformations
Event
Streamer
Event
Subscriber
constructor
max
Queue
Size
queue
socket
default
Max
Listeners
add
Listener
close
emit
event
Names
get
Max
Listeners
listener
Count
listeners
on
once
prepend
Listener
prepend
Once
Listener
raw
Listeners
remove
All
Listeners
remove
Listener
set
Max
Listeners
listener
Count
Filter
Set
Generated using
TypeDoc