def peek.cursor.front.request

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

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

307def peek.cursor.front.request(
308  pair: Protocol.Request & Maybe<&2, U32>,
309  +connection_id: U32,
310  accepted_sequence: Nat,
311  deadline_ms: Nat,
312  encoded_bytes: Nat,
313  response_peak: Nat,
314  tail: List<&1, Pending>,
315  back: List<&1, Pending>,
316  count: Nat,
317  bytes: Nat
318) -> CursorPeek:
319  match pair:
320    case (retained_request, cursor_id):
321      CursorPeek{Queue{Con{Pending{connection_id, accepted_sequence,
322        deadline_ms, encoded_bytes, response_peak, retained_request},
323        tail}, back, count, bytes}, cursor_id, connection_id}