Current section
Files
Jump to
Current section
Files
src/gossamer/transform_stream/default_controller.ffi.mjs
// src/utils/result.ts
import { Result$Error, Result$Ok } from "../../../prelude.mjs";
function toResult(value) {
return value === null || value === void 0 ? Result$Error(void 0) : Result$Ok(value);
}
toResult.fromThrows = function(throws) {
try {
return Result$Ok(throws());
} catch (error2) {
return Result$Error(
error2 instanceof Error ? error2.message : String(error2)
);
}
};
toResult.fromPromise = function(promise) {
return promise.then(
(value) => Result$Ok(value),
(error2) => Result$Error(error2 instanceof Error ? error2.message : String(error2))
);
};
// src/gossamer/transform_stream/default_controller.ffi.ts
var desired_size = (controller) => {
return toResult(controller.desiredSize);
};
var enqueue = (controller, chunk) => {
controller.enqueue(chunk);
};
var error = (controller, reason) => {
controller.error(reason);
};
var terminate = (controller) => {
controller.terminate();
};
export {
desired_size,
enqueue,
error,
terminate
};