ClientPolicy.request_id.take: def of mylsm-lsm-store@0.6.0.1 Import: import mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend as ClientPolicy Lines 123-128 of mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend: https://jend.leeeet.dev/read.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend&start_line=123&end_line=128 import Base import mylsm-lsm-store@0.6.0.1/src/coordinator/Protocol.bend as Protocol # Assigns each request ID once and makes exhaustion terminal. def request_id.take(sequence: RequestSequence) -> RequestDecision: match sequence: case RequestAvailable{id}: request_id.take.ready(Protocol.u32.duplicate.triple(id)) case RequestExhausted{}: RequestIdsExhausted{} Uses (4): https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend&name=RequestDecision https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend&name=RequestSequence https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend&name=request_id.take.ready https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/Protocol.bend&name=u32.duplicate.triple