Mylsm.Bytes.scan_next.owned: def of mylsm-lsm-store@0.6.0.1
Import: import mylsm-lsm-store@0.6.0.1/mylsm.bend as Mylsm
Lines 1676-1694 of mylsm-lsm-store@0.6.0.1/mylsm.bend: https://jend.leeeet.dev/read.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&start_line=1676&end_line=1694

import Base
import mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend as ByteMemTable
import mylsm-lsm-store@0.6.0.1/src/scan/RangeCursor.bend as ByteRangeCursor

def Bytes.scan_next.owned(
  snapshot: Bytes.Snapshot,
  bounds: ByteRangeCursor.Bounds,
  step: Bytes.StreamStep
) -> IO(Bytes.StreamStep):
  match step:
    case StreamItem{key, value, inner}:
      IO.pure(Bytes.StreamStep, Bytes.scan_next.owned.checked(snapshot, inner,
        ByteRangeCursor.key.copies.first(ByteMemTable.bytes.clone(key)), value,
        ByteRangeCursor.bounds.clone(bounds)))
    case StreamSkip{inner}:
      IO.pure(Bytes.StreamStep, StreamSkip{ByteOwnedCursor{snapshot, inner, bounds}})
    case StreamFailure{error, inner}:
      IO.pure(Bytes.StreamStep, StreamFailure{error, ByteOwnedCursor{snapshot, inner, bounds}})
    case StreamEnd{inner}:
      do IO<Bytes.StreamStep>:
        closed : Result<&1, &1, Bytes.Error, Unit> <-
          Bytes.scan_close(ByteOwnedCursor{snapshot, inner, bounds})
        return Bytes.scan_next.owned.ended(closed)

Uses (16):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO.bind
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO.pure
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Result
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Unit
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&name=Bytes.Cursor
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&name=Bytes.Error
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&name=Bytes.Snapshot
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&name=Bytes.StreamStep
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&name=Bytes.scan_close
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&name=Bytes.scan_next.owned.checked
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/mylsm.bend&name=Bytes.scan_next.owned.ended
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend&name=bytes.clone
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/scan/RangeCursor.bend&name=Bounds
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/scan/RangeCursor.bend&name=bounds.clone
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/scan/RangeCursor.bend&name=key.copies.first