Skip to content

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 error is provided, the receiver re-raises it from .next() once any buffered values have been drained

Parameters

NameTypeDescription
error? Optional error value to propagate
:backtrace? strand.Backtrace Optional backtrace for that error

Example

send.close()
send.close "boom"

put value

Sends a value, waiting while the channel's buffer is full.

Parameters

NameTypeDescription
value T Value to send.

Errors

Exception Condition
StateError The sender is closed
SinkStop The receiver is closed