def active

mylsm-lsm-store@0.6.0.1 · src/coordinator/RequestQueue.bend:75

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend as Policy

75# Handles active.
76def active(queue: Queue) -> Queue & Bool:
77  match queue:
78    case Queue{front, back, +count, bytes}:
79      active.counted(front, back, bytes,
80        Policy.nat.clone.pair(count))