Sender[T]
Sends values into a channel. As a Sink, it accepts put.
Senders are returned by channel.
Inherits from: std.Sink[T]
Methods
close …
Closes the sender, signaling EOF to receivers. After closing:
- Sends will fail
- Receivers will eventually see no more values
- If
erroris provided, the receiver re-raises it from.next()once any buffered values have been drained
Parameters
| Name | Type | Description |
|---|---|---|
error? |
Optional error value to propagate | |
:backtrace? |
strand.Backtrace |
Optional backtrace for that error |
Example
put value
Sends a value, waiting while the channel's buffer is full.
Parameters
| Name | Type | Description |
|---|---|---|
value |
T |
Value to send. |
Errors
| Exception | Condition |
|---|---|
StateError |
The sender is closed |
SinkStop |
The receiver is closed |