concurrency v3.0.1 (2021-07-07T14:50:22Z)
Dub
Repo
StreamObjectBase
concurrency
stream
A polymorphic stream with elements of type T
interface
StreamObjectBase (
T
) {
interface
SenderObjectBase
(T)
via
import
concurrency
.
sender
:
SenderObjectBase
;
;
alias
ElementType
=
T
;
alias
DG
=
CollectDelegate
!(
ElementType
)
;
SenderObjectBase
!
void
collect
(DG dg);
}
Members
Aliases
DG
alias
DG
=
CollectDelegate
!(
ElementType
)
Undocumented in source.
ElementType
alias
ElementType
=
T
Undocumented in source.
Functions
collect
SenderObjectBase
!
void
collect
(DG dg)
Undocumented in source.
Meta
Source
See Implementation
concurrency
stream
classes
StreamObjectImpl
enums
ThrottleEmitLogic
ThrottleTimerLogic
isStream
functions
arrayStream
checkStream
debounce
doneStream
errorStream
fromStreamOp
infiniteStream
intervalStream
iotaStream
sample
scan
sharedStream
slide
take
throttleFirst
throttleLast
throttling
toList
toStreamObject
transform
via
interfaces
StreamObjectBase
structs
SharedStream
templates
CollectDelegate
SchedulerType
StreamProperties
loopStream
A polymorphic stream with elements of type T