ChannelInt

Object Hierarchy:

Description:

    var ch = new ChannelInt ();
    new Thread<void *> ("sender", () => {
        ch.send (42);
        return null;
    });
    int val = ch.receive ();

    var created = ChannelInt.buffered (10);
    if (created.isError ()) {
        return;
    }
    var ch = created.unwrap ();
    ch.send (1);
    ch.send (2);
    int v1 = ch.receive ();
    int v2 = ch.receive ();

Content:

Static methods:

• public static Result<ChannelInt,Error> buffered (int capacity)
  Creates a buffered channel with the given capacity.

Creation methods:

• public ChannelInt ()
  Creates an unbuffered channel. Send blocks until a receiver is ready (rendezvous).

Methods:

• public int capacity ()
  Returns the buffer capacity. 0 means unbuffered.
• public void close ()
  Closes the channel. No more values can be sent. Pending receives will drain remaining values, then return 0 for subsequent calls.
• public bool isClosed ()
  Returns whether the channel is closed.
• public int receive ()
  Receives a value from the channel, blocking until one is available. Returns the default value (0) if the channel is closed and empty.
• public void send (int value)
  Sends a value into the channel. For buffered channels, blocks if the buffer is full. For unbuffered channels, blocks until a receiver calls receive (strict rendezvous: only one sender in flight at a time). Logs a warning and returns if the channel is closed.
• public int size ()
  Returns the number of items currently in the buffer.
• public IntBox? tryReceive ()
  Tries to receive a value without blocking.
• public bool trySend (int value)
  Tries to send a value without blocking.

Inherited Members: