io.github.libtmux.control.EventSubscription.EventSubscription

class io.github.libtmux.control.EventSubscription.EventSubscription

classreadonly [source] ¶

classreadonly [source] ¶

class io.github.libtmux.control.EventSubscription.EventSubscription

Pulls events volunteered by one control client.

<p>Each subscription owns a fixed-capacity buffer. When that buffer is full, the next event replaces its oldest event and increments #droppedCount() ; another subscription has its own buffer and loss count. The control protocol reader only offers values to these buffers. It never runs subscriber code. Public operations are thread-safe; concurrent readers compete for the same sequence, and each event is returned at most once.

<p>Closing is terminal: it discards buffered events, wakes threads blocked in #next() , and makes every later read return empty. Events discarded by close are not overflow and do not increment the loss count.

Members

• close method Discards buffered events, removes this subscriber, and wakes every waiting reader.
• droppedCount method Returns the exact number of events discarded because this subscription's buffer was full.
• EventSubscription method
• isClosed method Whether this subscription has reached its terminal state.
• next method Waits until the next event arrives or this subscription closes.
• offer method