def rx.live

mylsm-lsm-store@0.6.0.1 · src/coordinator/TransportBudgetPolicy.bend:330

import Base

330def rx.live(owns_credit: Bool) -> RxInterest:
331  match owns_credit:
332    case True{}: ReadEnabled{}
333    case False{}: ReadPaused{}