Channel

---

Object Hierarchy:

Description:

Content:

Static methods:

• public static Result<Channel<T>,Error> buffered<T> (int capacity)
  Creates a buffered channel.
• public static Channel<T> fanIn<T> (ArrayList<Channel<T>> sources)
  Merges multiple source channels into one output channel.
• public static Result<ArrayList<Channel<T>>,Error> fanOut<T> (Channel<T> src, int n)
  Distributes values from source channel to n output channels.
• public static Channel<U> pipeline<T,U> (Channel<T> input, owned MapFunc<T,U> fn)
  Builds a transform pipeline channel.
• public static Pair<int,T>? select<T> (ArrayList<Channel<T>> channels)
  Waits until one channel becomes receivable.

Creation methods:

• public Channel ()
  Creates an unbuffered channel.

Methods:

• public int capacity ()
  Returns buffer capacity (0 for unbuffered).
• public void close ()
  Closes channel for further sends.
• public bool isClosed ()
  Returns whether channel is closed.
• public T receive ()
  Receives a value, blocking until one is available.
• public T receiveTimeout (Duration timeout)
  Receives with timeout.
• public void send (T value)
  Sends a value to the channel.
• public int size ()
  Returns current buffered size.
• public T tryReceive ()
  Tries to receive a value without blocking.
• public bool trySend (T value)
  Tries to send a value without blocking.

Inherited Members: