Type parameters
T
Hierarchy
Mult
Implements
IWriteableChannel
<
T
>
Index
Constructors
constructor
Properties
src
tapID
taps
nextID
Accessors
id
Methods
channel
close
process
tap
untap
untap
All
write
Constructors
constructor
new
Mult<T>
(
)
:
Mult
<
T
>
new
Mult<T>
(
id
:
string
)
:
Mult
<
T
>
new
Mult<T>
(
src
:
Channel
<
T
>
)
:
Mult
<
T
>
new
Mult<T>
(
tx
:
Transducer
<
any
,
T
>
)
:
Mult
<
T
>
new
Mult<T>
(
id
:
string
, tx
:
Transducer
<
any
,
T
>
)
:
Mult
<
T
>
Type parameters
T
Returns
Mult
<
T
>
Type parameters
T
Parameters
id:
string
Returns
Mult
<
T
>
Type parameters
T
Parameters
src:
Channel
<
T
>
Returns
Mult
<
T
>
Type parameters
T
Parameters
tx:
Transducer
<
any
,
T
>
Returns
Mult
<
T
>
Type parameters
T
Parameters
id:
string
tx:
Transducer
<
any
,
T
>
Returns
Mult
<
T
>
Properties
Protected
src
src
:
Channel
<
any
>
Protected
tapID
tapID
:
number
= 0
Protected
taps
taps
:
DCons
<
Channel
<
any
>
>
Protected
Static
nextID
nextID
:
number
= 0
Accessors
id
get
id
(
)
:
string
set
id
(
id
:
string
)
:
void
Returns
string
Parameters
id:
string
Returns
void
Methods
channel
channel
(
)
:
Channel
<
any
>
Returns
Channel
<
any
>
close
close
(
flush
?:
boolean
)
:
undefined
|
Promise
<
void
>
Parameters
flush:
boolean
= false
Returns
undefined
|
Promise
<
void
>
Protected
process
process
(
)
:
Promise
<
void
>
Returns
Promise
<
void
>
tap
tap<R>
(
ch
?:
Channel
<
R
>
|
Transducer
<
T
,
R
>
)
:
undefined
|
Channel
<
R
>
Type parameters
R
Parameters
Optional
ch:
Channel
<
R
>
|
Transducer
<
T
,
R
>
Returns
undefined
|
Channel
<
R
>
untap
untap
(
ch
:
Channel
<
any
>
)
:
boolean
Parameters
ch:
Channel
<
any
>
Returns
boolean
untap
All
untap
All
(
close
?:
boolean
)
:
boolean
Parameters
close:
boolean
= true
Returns
boolean
write
write
(
val
:
any
)
:
Promise
<
boolean
>
Parameters
val:
any
Returns
Promise
<
boolean
>
Exports
Channel
Dropping
Buffer
Fixed
Buffer
Mult
constructor
src
tapID
taps
nextID
id
channel
close
process
tap
untap
untap
All
write
Pub
Sub
Sliding
Buffer
Channel
Item
IBuffer
IChannel
IRead
Writeable
Channel
IReadable
Channel
IWriteable
Channel
Error
Handler
Topic
Fn
Generated using
TypeDoc