concurrency ~master (2022-01-07T14:23:47Z)
Dub
Repo
StreamObjectImpl
concurrency
stream
stream
A class extending from StreamObjectBase that wraps any Stream
class
StreamObjectImpl : StreamObjectBase!(Stream.ElementType)(
Stream
)
if
(
models
!(
Stream
,
isStream
)
) {
interface
ReceiverObjectBase
(T)
via
import
concurrency
.
receiver
:
ReceiverObjectBase
;
;
this
(Stream stream);
alias
DG
=
CollectDelegate
!(
Stream
.
ElementType
)
;
SenderObjectBase
!
void
collect
(DG dg);
}
Constructors
this
this
(Stream stream)
Undocumented in source.
Members
Aliases
DG
alias
DG
=
CollectDelegate
!(
Stream
.
ElementType
)
Undocumented in source.
Functions
collect
SenderObjectBase
!
void
collect
(DG dg)
Undocumented in source. Be warned that the author may not have intended to support it.
Meta
Source
See Implementation
concurrency
stream
stream
classes
StreamObjectImpl
enums
isStream
functions
checkStream
fromStreamOp
toStreamObject
interfaces
StreamObjectBase
templates
CollectDelegate
SchedulerType
StreamProperties
loopStream
A class extending from StreamObjectBase that wraps any Stream