concurrency ~master (2022-01-07T14:23:47Z)
Dub
Repo
SenderObjectBase
concurrency
sender
A polymorphic sender of type T
interface
SenderObjectBase (
T
) {
import
concurrency
.
receiver
;
;
interface
SchedulerObjectBase
via
import
concurrency
.
scheduler
:
SchedulerObjectBase
;
;
struct
StopToken
via
import
concurrency
.
stoptoken
:
StopToken
,
stopTokenObject
;
;
auto
stopTokenObject
(NeverStopToken stopToken) via
import
concurrency
.
stoptoken
:
StopToken
,
stopTokenObject
;
;
alias
Value
=
T
;
alias
Op
=
OperationObject
;
OperationObject
connect
(ReceiverObjectBase!(T) receiver);
OperationObject
connect
(Receiver receiver);
}
Members
Aliases
Op
alias
Op
=
OperationObject
Undocumented in source.
Value
alias
Value
=
T
Undocumented in source.
Functions
connect
OperationObject
connect
(ReceiverObjectBase!(T) receiver)
Undocumented in source.
connect
OperationObject
connect
(Receiver receiver)
Undocumented in source. Be warned that the author may not have intended to support it.
Meta
Source
See Implementation
concurrency
sender
classes
PromiseSender
SenderObjectImpl
enums
isSender
functions
checkSender
connectHeap
delay
just
justFrom
promise
toSenderObject
interfaces
OperationalStateBase
SenderObjectBase
structs
DelaySender
DoneSender
ErrorSender
JustFromSender
OperationObject
PromiseSenderOp
ThrowingSender
ValueSender
VoidSender
templates
OpType
isValidOp
A polymorphic sender of type T