@mjt-engine/message
Preparing search index...
Messages
Variable Messages
Const
Messages
:
{
connectEventListenerToSubjectRoot
:
<
S
extends
string
,
EM
extends
EventMap
<
S
>
,
E
extends
Record
<
string
,
string
>
=
Record
<
string
,
string
>
,
>
(
__namedParameters
:
{
connection
:
NatsConnection
;
env
?:
Partial
<
E
>
;
listener
:
EventListener
<
S
,
EM
,
E
>
;
onError
?:
(
error
:
unknown
)
=>
void
;
options
?:
Partial
<
{
log
:
(
message
:
unknown
,
...
extra
:
unknown
[]
)
=>
void
;
maxMessages
?:
number
;
queue
?:
string
;
timeout
?:
number
;
}
,
>
;
signal
?:
AbortSignal
;
subjectRoot
:
string
;
}
,
)
=>
Promise
<
void
>
;
createConnection
:
<
CM
extends
ConnectionMap
,
E
extends
Record
<
string
,
string
>
=
Record
<
string
,
string
>
,
>
(
__namedParameters
:
{
creds
?:
string
;
env
?:
Partial
<
E
>
;
options
?:
Partial
<
{
log
:
(
message
:
unknown
,
...
extra
:
unknown
[]
)
=>
void
;
maxMessageSize
?:
number
;
}
,
>
;
server
:
string
|
string
[]
;
subscribers
?:
Partial
<
{
[
k
in
string
|
number
|
symbol
]
:
ConnectionListener
<
CM
,
k
,
E
>
}
,
>
;
token
?:
string
;
}
,
)
=>
Promise
<
MessageConnectionInstance
<
CM
>
>
;
parseSubject
:
<
T
extends
string
=
string
>
(
subject
:
PartialSubject
<
T
>
,
)
=>
ParsedSubject
<
T
>
;
}
= ...
Type declaration
connectEventListenerToSubjectRoot
:
<
S
extends
string
,
EM
extends
EventMap
<
S
>
,
E
extends
Record
<
string
,
string
>
=
Record
<
string
,
string
>
,
>
(
__namedParameters
:
{
connection
:
NatsConnection
;
env
?:
Partial
<
E
>
;
listener
:
EventListener
<
S
,
EM
,
E
>
;
onError
?:
(
error
:
unknown
)
=>
void
;
options
?:
Partial
<
{
log
:
(
message
:
unknown
,
...
extra
:
unknown
[]
)
=>
void
;
maxMessages
?:
number
;
queue
?:
string
;
timeout
?:
number
;
}
,
>
;
signal
?:
AbortSignal
;
subjectRoot
:
string
;
}
,
)
=>
Promise
<
void
>
createConnection
:
<
CM
extends
ConnectionMap
,
E
extends
Record
<
string
,
string
>
=
Record
<
string
,
string
>
,
>
(
__namedParameters
:
{
creds
?:
string
;
env
?:
Partial
<
E
>
;
options
?:
Partial
<
{
log
:
(
message
:
unknown
,
...
extra
:
unknown
[]
)
=>
void
;
maxMessageSize
?:
number
;
}
,
>
;
server
:
string
|
string
[]
;
subscribers
?:
Partial
<
{
[
k
in
string
|
number
|
symbol
]
:
ConnectionListener
<
CM
,
k
,
E
>
}
,
>
;
token
?:
string
;
}
,
)
=>
Promise
<
MessageConnectionInstance
<
CM
>
>
parseSubject
:
<
T
extends
string
=
string
>
(
subject
:
PartialSubject
<
T
>
)
=>
ParsedSubject
<
T
>
Settings
Member Visibility
Protected
Inherited
External
Theme
OS
Light
Dark
@mjt-engine/message
Loading...