MessageQueue

Object Hierarchy:

Description:

  var items = new Gee.ArrayList<Message>();  // session-owned
  var q = new MessageQueue(items);
  q.append(user_msg);
  user_msg.role = "urgent";   // UI escalates

  // Session load: swap backing list (ColumnView keeps the same model)
  q.items = loaded_session.queued_messages;

  // Drain most recent urgent via FilterListModel, then remove from q
  var urgent = new Gtk.FilterListModel(q, new Gtk.CustomFilter((item) => {
      return ((Message) item).role == "urgent";
  }));
  if (urgent.get_n_items() > 0) {
      var msg = (Message) urgent.get_item(urgent.get_n_items() - 1);
      q.remove(msg);
      msg.role = "user";
  }

Content:

Properties:

• public ArrayList<Message> items { get; set; }
  Backing store of queued messages (append order = enqueue time).

Creation methods:

• public MessageQueue (ArrayList<Message> items)

Methods:

• public void append (Message message)
  Append a message (ListStore-compatible). Emits items_changed.
• public bool contains (Message message)
  Whether message is in the queue.
• public bool find (Message message, out uint position)
  Find message and return its position.
• public Object? get_item (uint position)
  ListModel: item at position.
• public Type get_item_type ()
  ListModel: item type.
• public uint get_n_items ()
  ListModel: number of items.
• public void insert (uint position, Message message)
  Unsupported — queue is append-only. Asserts not reached.
• public void remove (Message message)
  Remove by reference (ListStore-compatible).
• public void remove_all ()
  Remove all rows (ListStore-compatible).
• public void remove_at (uint position)
  Remove at position (ListStore-compatible). Emits items_changed.

Signals:

• public signal void can_queue (bool enabled)
  Relay: Agent / Factory emit to toggle mid-run composer + strip. ChatWidget connects; this class does not store the flag.

Inherited Members: