effect-fluent
Advanced tools
Comparing version
@@ -7,3 +7,3 @@ "use strict"; | ||
exports.Effect = void 0; | ||
const effect_1 = /*#__PURE__*/require("effect"); | ||
var _effect = require("effect"); | ||
class Effect { | ||
@@ -15,18 +15,18 @@ value; | ||
static succeed(value) { | ||
return new Effect(effect_1.Effect.succeed(value)); | ||
return new Effect(_effect.Effect.succeed(value)); | ||
} | ||
static fail(error) { | ||
return new Effect(effect_1.Effect.fail(error)); | ||
return new Effect(_effect.Effect.fail(error)); | ||
} | ||
static die(error) { | ||
return new Effect(effect_1.Effect.die(error)); | ||
return new Effect(_effect.Effect.die(error)); | ||
} | ||
static sync(thunk) { | ||
return new Effect(effect_1.Effect.sync(thunk)); | ||
return new Effect(_effect.Effect.sync(thunk)); | ||
} | ||
static suspend(action) { | ||
return new Effect(effect_1.Effect.suspend(action)); | ||
return new Effect(_effect.Effect.suspend(action)); | ||
} | ||
static async(resume, blockingOn) { | ||
return new Effect(effect_1.Effect.async(callback => { | ||
return new Effect(_effect.Effect.async(callback => { | ||
// TODO: the abort signal is wrong | ||
@@ -41,7 +41,7 @@ const res = resume(io => callback(io.value), new AbortSignal()); | ||
static promise(evaluate) { | ||
return new Effect(effect_1.Effect.promise(evaluate)); | ||
return new Effect(_effect.Effect.promise(evaluate)); | ||
} | ||
static tryPromise(arg) { | ||
// TODO: fix as any | ||
return new Effect(effect_1.Effect.tryPromise(arg)); | ||
return new Effect(_effect.Effect.tryPromise(arg)); | ||
} | ||
@@ -52,6 +52,6 @@ constructor(value) { | ||
map(f) { | ||
return new Effect(effect_1.Effect.map(this.value, f)); | ||
return new Effect(_effect.Effect.map(this.value, f)); | ||
} | ||
flatMap(f) { | ||
return new Effect(effect_1.Effect.flatMap(this.value, a => f(a).value)); | ||
return new Effect(_effect.Effect.flatMap(this.value, a => f(a).value)); | ||
} | ||
@@ -58,0 +58,0 @@ with(f) { |
@@ -6,10 +6,9 @@ "use strict"; | ||
}); | ||
exports.Effect = void 0; | ||
var Effect_1 = /*#__PURE__*/require("./Effect"); | ||
Object.defineProperty(exports, "Effect", { | ||
enumerable: true, | ||
get: function () { | ||
return Effect_1.Effect; | ||
return _Effect.Effect; | ||
} | ||
}); | ||
var _Effect = require("./Effect.js"); | ||
//# sourceMappingURL=index.js.map |
@@ -1,2 +0,2 @@ | ||
export { Effect } from './Effect'; | ||
export { Effect } from './Effect.js'; | ||
//# sourceMappingURL=index.d.ts.map |
@@ -1,9 +0,3 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { | ||
value: true | ||
}); | ||
exports.Effect = void 0; | ||
const effect_1 = /*#__PURE__*/require("effect"); | ||
class Effect { | ||
import { Effect as _Effect } from 'effect'; | ||
export class Effect { | ||
value; | ||
@@ -14,18 +8,18 @@ static of(effect) { | ||
static succeed(value) { | ||
return new Effect(effect_1.Effect.succeed(value)); | ||
return new Effect(_Effect.succeed(value)); | ||
} | ||
static fail(error) { | ||
return new Effect(effect_1.Effect.fail(error)); | ||
return new Effect(_Effect.fail(error)); | ||
} | ||
static die(error) { | ||
return new Effect(effect_1.Effect.die(error)); | ||
return new Effect(_Effect.die(error)); | ||
} | ||
static sync(thunk) { | ||
return new Effect(effect_1.Effect.sync(thunk)); | ||
return new Effect(_Effect.sync(thunk)); | ||
} | ||
static suspend(action) { | ||
return new Effect(effect_1.Effect.suspend(action)); | ||
return new Effect(_Effect.suspend(action)); | ||
} | ||
static async(resume, blockingOn) { | ||
return new Effect(effect_1.Effect.async(callback => { | ||
return new Effect(_Effect.async(callback => { | ||
// TODO: the abort signal is wrong | ||
@@ -40,7 +34,7 @@ const res = resume(io => callback(io.value), new AbortSignal()); | ||
static promise(evaluate) { | ||
return new Effect(effect_1.Effect.promise(evaluate)); | ||
return new Effect(_Effect.promise(evaluate)); | ||
} | ||
static tryPromise(arg) { | ||
// TODO: fix as any | ||
return new Effect(effect_1.Effect.tryPromise(arg)); | ||
return new Effect(_Effect.tryPromise(arg)); | ||
} | ||
@@ -51,6 +45,6 @@ constructor(value) { | ||
map(f) { | ||
return new Effect(effect_1.Effect.map(this.value, f)); | ||
return new Effect(_Effect.map(this.value, f)); | ||
} | ||
flatMap(f) { | ||
return new Effect(effect_1.Effect.flatMap(this.value, a => f(a).value)); | ||
return new Effect(_Effect.flatMap(this.value, a => f(a).value)); | ||
} | ||
@@ -61,3 +55,2 @@ with(f) { | ||
} | ||
exports.Effect = Effect; | ||
//# sourceMappingURL=Effect.js.map |
@@ -1,14 +0,2 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { | ||
value: true | ||
}); | ||
exports.Effect = void 0; | ||
var Effect_1 = /*#__PURE__*/require("./Effect"); | ||
Object.defineProperty(exports, "Effect", { | ||
enumerable: true, | ||
get: function () { | ||
return Effect_1.Effect; | ||
} | ||
}); | ||
export { Effect } from './Effect.js'; | ||
//# sourceMappingURL=index.js.map |
{ | ||
"name": "effect-fluent", | ||
"version": "0.0.2", | ||
"version": "0.0.3", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "license": "MIT", |
@@ -1,1 +0,1 @@ | ||
export { Effect } from './Effect'; | ||
export { Effect } from './Effect.js'; |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
0
-100%16472
-6.57%210
-7.89%