def read.nonblocking.classified

mylsm-lsm-store@0.6.0.1 · src/coordinator/Io.bend:128

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

128def read.nonblocking.classified(
129  file: File,
130  +code: U32,
131  message: String,
132  disposition: IoPolicy.ReadDisposition
133) -> File & ReadAttempt:
134  match disposition:
135    case IoPolicy.ReadInterrupted{}: (file, ReadInterrupted{})
136    case IoPolicy.ReadWouldBlock{}: (file, ReadWouldBlock{})
137    case IoPolicy.ReadFailure{}:
138      (file, ReadFailed{host.error(code, message)})