def transfer.written

bend-kit-stream@0.3.1.0 · stream.bend:83

import Base

83def transfer.written(~S: Type, ~D: Type, source: S, count: U32, len: U32,
84  pair: D & Result<&1, &1, U32 & String, Unit>) -> Transfer<S, D>:
85  (destination, result) = pair
86  match result:
87    case Fail{(code, message)}:
88      Stop{source, destination, Failed{count, Write{code, message}}}
89    case Done{unit}:
90      More{source, destination, (count + len : U32)}