~/jendhub

def Bytes.stream.step.result

mylsm-lsm-store@0.6.0.1 · mylsm.bend:1498

import mylsm-lsm-store@0.6.0.1/mylsm.bend as Mylsm
import Base
import mylsm-lsm-store@0.6.0.1/src/ByteDurableDb.bend as RawByteDb
import mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend as ByteMemTable
import mylsm-lsm-store@0.6.0.1/src/scan/VisibleCursor.bend as VisibleByteCursor

1498def Bytes.stream.step.result(step: VisibleByteCursor.Step) -> Bytes.StreamStep:
1499  match step:
1500    case VisibleByteCursor.Item{ByteMemTable.Entry{key, Some{value}}, cursor}:
1501      StreamItem{key, value, ByteStreamCursor{cursor}}
1502    case VisibleByteCursor.Item{ByteMemTable.Entry{_, None{}}, cursor}:
1503      StreamSkip{ByteStreamCursor{cursor}}
1504    case VisibleByteCursor.Skip{cursor}:
1505      StreamSkip{ByteStreamCursor{cursor}}
1506    case VisibleByteCursor.End{}:
1507      StreamEnd{ByteStreamCursor{VisibleByteCursor.Ended{}}}
1508    case VisibleByteCursor.Error{error}:
1509      StreamFailure{Bytes.error(RawByteDb.scan.error(error)),
1510        ByteStreamCursor{VisibleByteCursor.Ended{}}}

Uses (8)

Used by (1)