def write.nonblocking.classified

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

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/IoPolicy.bend as IoPolicy
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

176def write.nonblocking.classified(
177  file: File,
178  bytes: Bytes.Bytes,
179  +code: U32,
180  message: String,
181  disposition: IoPolicy.WriteDisposition
182) -> File & WriteAttempt:
183  match disposition:
184    case IoPolicy.WriteInterrupted{}:
185      (file, NonblockingWriteInterrupted{bytes})
186    case IoPolicy.WriteWouldBlock{}:
187      (file, NonblockingWriteWouldBlock{bytes})
188    case IoPolicy.WriteFailure{}:
189      (file, NonblockingWriteFailed{bytes, host.error(code, message)})