@nobrayner/orf - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

lib/orf.d.ts

@@ -939,6 +939,8 @@ type InferOkType$1<T> = T extends Result<infer U, any> ? U : never;
     /**
-     * Creates a new `FallibleFuture<T, E>` from the given `Result<T, E>`, or
-     * returns the given `FallibleFuture<T, E>` as is.
+     * Creates a new `FallibleFuture<T, E>` from the given "Fallible":
+     * - `Result<T, E>` as `FallibleFuture<T, E>`
+     * - `FallibleFuture<T, E>` as is
+     * - `Promise<T>` as `FallibleFuture<T, unknown>`
      */
-    function fromFallible<T, E>(f: Result<T, E> | FallibleFuture<T, E>): FallibleFuture<T, E>;
+    function fromFallible<T, E = unknown>(fallible: Result<T, E> | FallibleFuture<T, E> | Promise<T>): FallibleFuture<T, E>;
     /**
@@ -945,0 +947,0 @@ * Creates a new `Future<T>` with the value passed to `execute`s `resolve` function.

lib/orf.js

@@ -1,1 +0,1 @@
-"use strict";var W=Object.defineProperty;var re=Object.getOwnPropertyDescriptor;var ne=Object.getOwnPropertyNames;var ue=Object.prototype.hasOwnProperty;var oe=(u,e)=>{for(var t in e)W(u,t,{get:e[t],enumerable:!0})},ae=(u,e,t,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let o of ne(e))!ue.call(u,o)&&o!==t&&W(u,o,{get:()=>e[o],enumerable:!(n=re(e,o))||n.enumerable});return u};var ie=u=>ae(W({},"__esModule",{value:!0}),u);var X=(u,e,t)=>{if(!e.has(u))throw TypeError("Cannot "+t)};var r=(u,e,t)=>(X(u,e,"read from private field"),t?t.call(u):e.get(u)),x=(u,e,t)=>{if(e.has(u))throw TypeError("Cannot add the same private member more than once");e instanceof WeakSet?e.add(u):e.set(u,t)},E=(u,e,t,n)=>(X(u,e,"write to private field"),n?n.call(u,t):e.set(u,t),t);var K=(u,e,t)=>(X(u,e,"access private method"),t);var Z=(u,e,t)=>new Promise((n,o)=>{var O=_=>{try{y(t.next(_))}catch(i){o(i)}},s=_=>{try{y(t.throw(_))}catch(i){o(i)}},y=_=>_.done?n(_.value):Promise.resolve(_.value).then(O,s);y((t=t.apply(u,e)).next())});var se={};oe(se,{Future:()=>F,Option:()=>h,Result:()=>d});module.exports=ie(se);var Y=Error,d;(_=>{function u(i){return Object.freeze(new z(i))}_.Ok=u;function e(i){return Object.freeze(new A(i))}_.Error=e;function t(i){return i instanceof z||i instanceof A}_.isResult=t;function n(i,f){var U;try{return u(i())}catch(R){return e((U=f==null?void 0:f(R))!=null?U:R)}}_.fromExecution=n;function o(i,f){return Z(this,null,function*(){var U;try{return u(yield i)}catch(R){return e((U=f==null?void 0:f(R))!=null?U:R)}})}_.fromAwaitable=o;function O(i){let f=[];for(let U of i){if(U.isError())return U;f.push(U.unwrap())}return u(f)}_.all=O;function s(i){let f={};for(let U in i){let R=i[U];if(R.isError())return R;f[U]=R.unwrap()}return u(f)}_.allFromDict=s;function y(i){if(i.__orf_type__!=="Result"&&!("tag"in i))throw new Y("Invalid Result JSON");if(i.tag==="Ok"&&"value"in i)return u(i.value);if(i.tag==="Error"&&"error"in i)return e(i.error);throw new Y("Invalid Result JSON")}_.fromJSON=y})(d||(d={}));var z=class{constructor(e){this.value=e}isOk(){return!0}isError(){return!this.isOk()}match(e){return e.Ok(this.value)}map(e){return d.Ok(e(this.value))}mapOr(e,t){return t(this.value)}mapOrElse(e,t){return t(this.value)}mapError(e){return this}and(e){return e}andThen(e){return e(this.value)}or(e){return this}orElse(e){return this}tap(e){return e(Object.freeze(structuredClone(this.value))),this}tapError(e){return this}ok(){return h.Some(this.value)}unwrap(){return this.value}unwrapError(){throw new Y("Cannot unwrapError an Ok")}unwrapOr(e){return this.value}unwrapOrElse(e){return this.value}toJSON(){return{__orf_type__:"Result",tag:"Ok",value:this.value}}},A=class{constructor(e){this.error=e}isOk(){return!1}isError(){return!this.isOk()}match(e){return e.Error(this.error)}map(e){return this}mapOr(e,t){return e}mapOrElse(e,t){return e()}mapError(e){return d.Error(e(this.error))}and(e){return this}andThen(e){return this}or(e){return e}orElse(e){return e(this.error)}tap(e){return this}tapError(e){return e(Object.freeze(structuredClone(this.error))),this}ok(){return h.None()}unwrap(){throw this.error}unwrapError(){return this.error}unwrapOr(e){return e}unwrapOrElse(e){return e(this.error)}toJSON(){return{__orf_type__:"Result",tag:"Error",error:this.error}}};var h;(O=>{function u(s){return Object.freeze(new P(s))}O.Some=u;function e(){return le}O.None=e;function t(s){return s instanceof P||s instanceof q}O.isOption=t;function n(s){return s?u(s):e()}O.from=n;function o(s){if(s.__orf_type__!=="Option"&&!("tag"in s))throw new Error("Invalid Option JSON");if(s.tag==="Some"&&"value"in s)return u(s.value);if(s.tag==="None")return e();throw new Error("Invalid Option JSON")}O.fromJSON=o})(h||(h={}));var P=class{constructor(e){this.value=e}isSome(){return!0}isNone(){return!this.isSome()}match(e){return e.Some(this.value)}map(e){return h.Some(e(this.value))}mapOr(e,t){return t(this.value)}mapOrElse(e,t){return t(this.value)}and(e){return e}andThen(e){return e(this.value)}or(e){return this}orElse(e){return this}tap(e){return e(Object.freeze(structuredClone(this.value))),this}unwrap(){return this.value}unwrapOr(e){return this.value}unwrapOrElse(e){return this.value}okOr(e){return d.Ok(this.value)}okOrElse(e){return d.Ok(this.value)}toJSON(){return{__orf_type__:"Option",tag:"Some",value:this.value}}},q=class{isSome(){return!1}isNone(){return!this.isSome()}match(e){return e.None()}map(e){return this}mapOr(e,t){return e}mapOrElse(e,t){return e()}and(e){return this}andThen(e){return this}or(e){return e}orElse(e){return e()}tap(e){return this}unwrap(){throw new Error("Cannot unwrap None")}unwrapOr(e){return e}unwrapOrElse(e){return e()}okOr(e){return d.Error(e)}okOrElse(e){return d.Error(e())}toJSON(){return{__orf_type__:"Option",tag:"None"}}},le=Object.freeze(new q);var F;(C=>{function u(a){return new S({tag:"completed",value:a})}C.value=u;function e(a){return new b({tag:"completed",value:d.Ok(a)})}C.success=e;function t(a){return new b({tag:"completed",value:d.Error(a)})}C.fail=t;function n(a){return a instanceof S}C.isFuture=n;function o(a){return a instanceof b}C.isFallibleFuture=o;function O(a){return a instanceof b?a:a.match({Ok:T=>e(T),Error:T=>t(T)})}C.fromFallible=O;function s(a,T){return new S({tag:"pending",execute:a},T)}C.make=s;function y(a){return new S({tag:"pending",execute:a},{lazy:!0})}C.lazy=y;function _(a,T){return new b({tag:"pending",execute:a},T)}C.makeFallible=_;function i(a){return new b({tag:"pending",execute:a},{lazy:!0})}C.lazyFallible=i;function f(a){return new S({tag:"pending",execute:T=>{let g=setTimeout(T,a);return()=>{clearTimeout(g)}}})}C.wait=f;function U(a){let T=C.make(g=>{let M=new Array(a.length),N=0;return a.forEach((v,I)=>{v.onResolved(V=>{M[I]=V,N+=1,N===a.length&&g(M)})}),()=>a.forEach(v=>v.cancel())});return a.forEach(g=>g.onCancelled(T.cancel.bind(T))),T}C.all=U;function R(a){let T=Object.values(a),g=T.length;if(!T.some(C.isFallibleFuture)){let v=C.make(I=>{let V={},D=0;for(let w in a)a[w].onResolved(Q=>{V[w]=Q,D+=1,D===g&&I(V)});return()=>{for(let w of T)w.cancel()}});for(let I of T)I.onCancelled(v.cancel.bind(v));return v}let N=C.makeFallible((v,I)=>{let V={},D=0;for(let w in a){let J=a[w];C.isFuture(J)&&(J=J.neverError()),J.onResolved(Q=>{V[w]=Q,D+=1,D===g&&d.allFromDict(V).match({Ok:v,Error:I})})}return()=>{for(let w of T)w.cancel()}});for(let v of T)v.onCancelled(N.cancel.bind(N));return N}C.allFromDict=R})(F||(F={}));var c,B,$,S=class{constructor(e,t){x(this,B);x(this,c,void 0);E(this,c,e),t!=null&&t.lazy||this.then()}onResolved(e){var t;r(this,c).tag==="pending"?(r(this,c).resolve_callbacks=(t=r(this,c).resolve_callbacks)!=null?t:[],r(this,c).resolve_callbacks.push(e)):r(this,c).tag==="completed"&&e(r(this,c).value)}onCancelled(e){var t;r(this,c).tag==="pending"?(r(this,c).cancel_callbacks=(t=r(this,c).cancel_callbacks)!=null?t:[],r(this,c).cancel_callbacks.push(e)):r(this,c).tag==="cancelled"&&e()}cancel(){if(r(this,c).tag==="pending"){let{cancel:e,cancel_callbacks:t}=r(this,c);E(this,c,{tag:"cancelled"}),e==null||e(),t==null||t.forEach(n=>n())}}then(e){if(r(this,c).tag==="pending"&&r(this,c).execute){let t=r(this,c).execute(K(this,B,$).bind(this));r(this,c).execute=null,t&&(r(this,c).cancel=t)}return e&&(this.onResolved(t=>e(h.Some(t))),this.onCancelled(()=>e(h.None()))),this}map(e){let t=F.make(n=>(this.onResolved(o=>{n(e(o))}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}tap(e){return this.onResolved(e),this}neverError(){let e=F.makeFallible((t,n)=>(this.onResolved(t),this.cancel.bind(this)));return this.onCancelled(e.cancel.bind(e)),e}unwrap(){let e=new k({tag:"pending",execute:t=>{this.onResolved(t)}});return this.onCancelled(e.cancel.bind(e)),e}unwrapOr(e){return new k({tag:"pending",execute:n=>(this.onResolved(o=>{n(o)}),this.onCancelled(()=>{n(e)}),()=>{n(e)})})}unwrapOrElse(e){return new k({tag:"pending",execute:n=>(this.onResolved(o=>{n(o)}),this.onCancelled(()=>{n(e())}),()=>{n(e())})})}};c=new WeakMap,B=new WeakSet,$=function(e){if(r(this,c).tag==="pending"){let{resolve_callbacks:t}=r(this,c);E(this,c,{tag:"completed",value:e}),t==null||t.forEach(n=>n(e))}};var l,G,j,H,ee,b=class{constructor(e,t){x(this,G);x(this,H);x(this,l,void 0);E(this,l,e),t!=null&&t.lazy||this.then()}onResolved(e){var t;r(this,l).tag==="pending"?(r(this,l).resolve_callbacks=(t=r(this,l).resolve_callbacks)!=null?t:[],r(this,l).resolve_callbacks.push(e)):r(this,l).tag==="completed"&&e(r(this,l).value)}onSucceeded(e){this.onResolved(t=>{t.match({Ok:e,Error:()=>{}})})}onFailed(e){this.onResolved(t=>{t.match({Ok:()=>{},Error:e})})}onCancelled(e){var t;r(this,l).tag==="pending"?(r(this,l).cancel_callbacks=(t=r(this,l).cancel_callbacks)!=null?t:[],r(this,l).cancel_callbacks.push(e)):r(this,l).tag==="cancelled"&&e()}cancel(){if(r(this,l).tag==="pending"){let{cancel:e,cancel_callbacks:t}=r(this,l);E(this,l,{tag:"cancelled"}),e==null||e(),t==null||t.forEach(n=>n())}}then(e){if(r(this,l).tag==="pending"&&r(this,l).execute){let t=r(this,l).execute(K(this,G,j).bind(this),K(this,H,ee).bind(this));r(this,l).execute=null,t&&(r(this,l).cancel=t)}return e&&(this.onResolved(t=>e(h.Some(t))),this.onCancelled(()=>e(h.None()))),this}map(e){let t=F.makeFallible((n,o)=>(this.onResolved(O=>{O.match({Ok:s=>{n(e(s))},Error:o})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}mapError(e){let t=F.makeFallible((n,o)=>(this.onResolved(O=>{O.match({Ok:n,Error:s=>{o(e(s))}})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}andThen(e){let t=F.makeFallible((n,o)=>(this.onResolved(O=>{O.match({Ok:s=>{let y=F.fromFallible(e(s));y.onSucceeded(n),y.onFailed(o)},Error:o})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}orElse(e){let t=F.makeFallible((n,o)=>(this.onResolved(O=>{O.match({Ok:n,Error:s=>{let y=F.fromFallible(e(s));y.onSucceeded(n),y.onFailed(o)}})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}tap(e){return this.onSucceeded(e),this}tapError(e){return this.onFailed(e),this}ok(){let e=F.make(t=>(this.onSucceeded(n=>t(h.Some(n))),this.onFailed(()=>t(h.None())),this.cancel.bind(this)));return this.onCancelled(e.cancel.bind(e)),e}unwrap(){let e=new k({tag:"pending",execute:t=>{this.onResolved(n=>t(n.unwrap()))}});return this.onCancelled(e.cancel.bind(e)),e}unwrapError(){let e=new k({tag:"pending",execute:t=>{this.onResolved(n=>t(n.unwrapError()))}});return this.onCancelled(e.cancel.bind(e)),e}unwrapOr(e){return new k({tag:"pending",execute:n=>(this.onResolved(o=>{n(o.unwrapOr(e))}),this.onCancelled(()=>{n(e)}),()=>{n(e)})})}unwrapOrElse(e){return new k({tag:"pending",execute:n=>(this.onResolved(o=>{n(o.unwrapOrElse(e))}),this.onCancelled(()=>{n(e())}),()=>{n(e())})})}match(e){let t=new k({tag:"pending",execute:n=>{this.onResolved(o=>{n(o.match(e))})}});return this.onCancelled(t.cancel.bind(t)),t}};l=new WeakMap,G=new WeakSet,j=function(e){if(r(this,l).tag==="pending"){let{resolve_callbacks:t}=r(this,l),n=d.Ok(e);E(this,l,{tag:"completed",value:n}),t==null||t.forEach(o=>o(n))}},H=new WeakSet,ee=function(e){if(r(this,l).tag==="pending"){let{resolve_callbacks:t}=r(this,l),n=d.Error(e);E(this,l,{tag:"completed",value:n}),t==null||t.forEach(o=>o(n))}};var p,m,L,te,k=class{constructor(e){x(this,L);x(this,p,void 0);x(this,m,void 0);if(E(this,p,e),r(this,p).tag==="pending"&&r(this,p).execute){let t=r(this,p).execute(K(this,L,te).bind(this));r(this,p).execute=null,t&&!r(this,m)&&E(this,m,t)}}onResolved(e){var t;r(this,p).tag==="pending"?(r(this,p).resolve_callbacks=(t=r(this,p).resolve_callbacks)!=null?t:[],r(this,p).resolve_callbacks.push(e)):r(this,p).tag==="completed"&&e(r(this,p).value)}onCancelled(e){r(this,p).tag==="pending"&&!r(this,m)?E(this,m,e):r(this,p).tag==="cancelled"&&!r(this,m)&&e(new Error("Cannot cancel UnwrappedFuture"))}cancel(){r(this,p).tag==="pending"&&(r(this,m)?(r(this,m).call(this,new Error("Cannot cancel UnwrappedFuture")),r(this,p).tag==="pending"&&E(this,p,{tag:"cancelled"})):E(this,p,{tag:"cancelled"}))}then(e,t){return e&&this.onResolved(e),t&&this.onCancelled(t),this}};p=new WeakMap,m=new WeakMap,L=new WeakSet,te=function(e){if(r(this,p).tag==="pending"){let{resolve_callbacks:t}=r(this,p);E(this,p,{tag:"completed",value:e}),t==null||t.forEach(n=>n(e))}};0&&(module.exports={Future,Option,Result});
+"use strict";var W=Object.defineProperty;var ne=Object.getOwnPropertyDescriptor;var re=Object.getOwnPropertyNames;var ue=Object.prototype.hasOwnProperty;var oe=(u,e)=>{for(var t in e)W(u,t,{get:e[t],enumerable:!0})},ae=(u,e,t,r)=>{if(e&&typeof e=="object"||typeof e=="function")for(let a of re(e))!ue.call(u,a)&&a!==t&&W(u,a,{get:()=>e[a],enumerable:!(r=ne(e,a))||r.enumerable});return u};var ie=u=>ae(W({},"__esModule",{value:!0}),u);var X=(u,e,t)=>{if(!e.has(u))throw TypeError("Cannot "+t)};var n=(u,e,t)=>(X(u,e,"read from private field"),t?t.call(u):e.get(u)),g=(u,e,t)=>{if(e.has(u))throw TypeError("Cannot add the same private member more than once");e instanceof WeakSet?e.add(u):e.set(u,t)},E=(u,e,t,r)=>(X(u,e,"write to private field"),r?r.call(u,t):e.set(u,t),t);var K=(u,e,t)=>(X(u,e,"access private method"),t);var Z=(u,e,t)=>new Promise((r,a)=>{var O=w=>{try{y(t.next(w))}catch(i){a(i)}},s=w=>{try{y(t.throw(w))}catch(i){a(i)}},y=w=>w.done?r(w.value):Promise.resolve(w.value).then(O,s);y((t=t.apply(u,e)).next())});var se={};oe(se,{Future:()=>F,Option:()=>h,Result:()=>d});module.exports=ie(se);var Y=Error,d;(w=>{function u(i){return Object.freeze(new z(i))}w.Ok=u;function e(i){return Object.freeze(new A(i))}w.Error=e;function t(i){return i instanceof z||i instanceof A}w.isResult=t;function r(i,f){var U;try{return u(i())}catch(R){return e((U=f==null?void 0:f(R))!=null?U:R)}}w.fromExecution=r;function a(i,f){return Z(this,null,function*(){var U;try{return u(yield i)}catch(R){return e((U=f==null?void 0:f(R))!=null?U:R)}})}w.fromAwaitable=a;function O(i){let f=[];for(let U of i){if(U.isError())return U;f.push(U.unwrap())}return u(f)}w.all=O;function s(i){let f={};for(let U in i){let R=i[U];if(R.isError())return R;f[U]=R.unwrap()}return u(f)}w.allFromDict=s;function y(i){if(i.__orf_type__!=="Result"&&!("tag"in i))throw new Y("Invalid Result JSON");if(i.tag==="Ok"&&"value"in i)return u(i.value);if(i.tag==="Error"&&"error"in i)return e(i.error);throw new Y("Invalid Result JSON")}w.fromJSON=y})(d||(d={}));var z=class{constructor(e){this.value=e}isOk(){return!0}isError(){return!this.isOk()}match(e){return e.Ok(this.value)}map(e){return d.Ok(e(this.value))}mapOr(e,t){return t(this.value)}mapOrElse(e,t){return t(this.value)}mapError(e){return this}and(e){return e}andThen(e){return e(this.value)}or(e){return this}orElse(e){return this}tap(e){return e(Object.freeze(structuredClone(this.value))),this}tapError(e){return this}ok(){return h.Some(this.value)}unwrap(){return this.value}unwrapError(){throw new Y("Cannot unwrapError an Ok")}unwrapOr(e){return this.value}unwrapOrElse(e){return this.value}toJSON(){return{__orf_type__:"Result",tag:"Ok",value:this.value}}},A=class{constructor(e){this.error=e}isOk(){return!1}isError(){return!this.isOk()}match(e){return e.Error(this.error)}map(e){return this}mapOr(e,t){return e}mapOrElse(e,t){return e()}mapError(e){return d.Error(e(this.error))}and(e){return this}andThen(e){return this}or(e){return e}orElse(e){return e(this.error)}tap(e){return this}tapError(e){return e(Object.freeze(structuredClone(this.error))),this}ok(){return h.None()}unwrap(){throw this.error}unwrapError(){return this.error}unwrapOr(e){return e}unwrapOrElse(e){return e(this.error)}toJSON(){return{__orf_type__:"Result",tag:"Error",error:this.error}}};var h;(O=>{function u(s){return Object.freeze(new P(s))}O.Some=u;function e(){return le}O.None=e;function t(s){return s instanceof P||s instanceof q}O.isOption=t;function r(s){return s?u(s):e()}O.from=r;function a(s){if(s.__orf_type__!=="Option"&&!("tag"in s))throw new Error("Invalid Option JSON");if(s.tag==="Some"&&"value"in s)return u(s.value);if(s.tag==="None")return e();throw new Error("Invalid Option JSON")}O.fromJSON=a})(h||(h={}));var P=class{constructor(e){this.value=e}isSome(){return!0}isNone(){return!this.isSome()}match(e){return e.Some(this.value)}map(e){return h.Some(e(this.value))}mapOr(e,t){return t(this.value)}mapOrElse(e,t){return t(this.value)}and(e){return e}andThen(e){return e(this.value)}or(e){return this}orElse(e){return this}tap(e){return e(Object.freeze(structuredClone(this.value))),this}unwrap(){return this.value}unwrapOr(e){return this.value}unwrapOrElse(e){return this.value}okOr(e){return d.Ok(this.value)}okOrElse(e){return d.Ok(this.value)}toJSON(){return{__orf_type__:"Option",tag:"Some",value:this.value}}},q=class{isSome(){return!1}isNone(){return!this.isSome()}match(e){return e.None()}map(e){return this}mapOr(e,t){return e}mapOrElse(e,t){return e()}and(e){return this}andThen(e){return this}or(e){return e}orElse(e){return e()}tap(e){return this}unwrap(){throw new Error("Cannot unwrap None")}unwrapOr(e){return e}unwrapOrElse(e){return e()}okOr(e){return d.Error(e)}okOrElse(e){return d.Error(e())}toJSON(){return{__orf_type__:"Option",tag:"None"}}},le=Object.freeze(new q);var F;(N=>{function u(o){return new S({tag:"completed",value:o})}N.value=u;function e(o){return new b({tag:"completed",value:d.Ok(o)})}N.success=e;function t(o){return new b({tag:"completed",value:d.Error(o)})}N.fail=t;function r(o){return o instanceof S}N.isFuture=r;function a(o){return o instanceof b}N.isFallibleFuture=a;function O(o){return o instanceof b?o:o instanceof Promise?N.makeFallible((T,m)=>{o.then(T).catch(m)}):o.match({Ok:T=>e(T),Error:T=>t(T)})}N.fromFallible=O;function s(o,T){return new S({tag:"pending",execute:o},T)}N.make=s;function y(o){return new S({tag:"pending",execute:o},{lazy:!0})}N.lazy=y;function w(o,T){return new b({tag:"pending",execute:o},T)}N.makeFallible=w;function i(o){return new b({tag:"pending",execute:o},{lazy:!0})}N.lazyFallible=i;function f(o){return new S({tag:"pending",execute:T=>{let m=setTimeout(T,o);return()=>{clearTimeout(m)}}})}N.wait=f;function U(o){let T=N.make(m=>{let M=new Array(o.length),C=0;return o.forEach((v,I)=>{v.onResolved(V=>{M[I]=V,C+=1,C===o.length&&m(M)})}),()=>o.forEach(v=>v.cancel())});return o.forEach(m=>m.onCancelled(T.cancel.bind(T))),T}N.all=U;function R(o){let T=Object.values(o),m=T.length;if(!T.some(N.isFallibleFuture)){let v=N.make(I=>{let V={},D=0;for(let x in o)o[x].onResolved(Q=>{V[x]=Q,D+=1,D===m&&I(V)});return()=>{for(let x of T)x.cancel()}});for(let I of T)I.onCancelled(v.cancel.bind(v));return v}let C=N.makeFallible((v,I)=>{let V={},D=0;for(let x in o){let J=o[x];N.isFuture(J)&&(J=J.neverError()),J.onResolved(Q=>{V[x]=Q,D+=1,D===m&&d.allFromDict(V).match({Ok:v,Error:I})})}return()=>{for(let x of T)x.cancel()}});for(let v of T)v.onCancelled(C.cancel.bind(C));return C}N.allFromDict=R})(F||(F={}));var c,B,$,S=class{constructor(e,t){g(this,B);g(this,c,void 0);E(this,c,e),t!=null&&t.lazy||this.then()}onResolved(e){var t;n(this,c).tag==="pending"?(n(this,c).resolve_callbacks=(t=n(this,c).resolve_callbacks)!=null?t:[],n(this,c).resolve_callbacks.push(e)):n(this,c).tag==="completed"&&e(n(this,c).value)}onCancelled(e){var t;n(this,c).tag==="pending"?(n(this,c).cancel_callbacks=(t=n(this,c).cancel_callbacks)!=null?t:[],n(this,c).cancel_callbacks.push(e)):n(this,c).tag==="cancelled"&&e()}cancel(){if(n(this,c).tag==="pending"){let{cancel:e,cancel_callbacks:t}=n(this,c);E(this,c,{tag:"cancelled"}),e==null||e(),t==null||t.forEach(r=>r())}}then(e){if(n(this,c).tag==="pending"&&n(this,c).execute){let t=n(this,c).execute(K(this,B,$).bind(this));n(this,c).execute=null,t&&(n(this,c).cancel=t)}return e&&(this.onResolved(t=>e(h.Some(t))),this.onCancelled(()=>e(h.None()))),this}map(e){let t=F.make(r=>(this.onResolved(a=>{r(e(a))}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}tap(e){return this.onResolved(e),this}neverError(){let e=F.makeFallible((t,r)=>(this.onResolved(t),this.cancel.bind(this)));return this.onCancelled(e.cancel.bind(e)),e}unwrap(){let e=new _({tag:"pending",execute:t=>{this.onResolved(t)}});return this.onCancelled(e.cancel.bind(e)),e}unwrapOr(e){return new _({tag:"pending",execute:r=>(this.onResolved(a=>{r(a)}),this.onCancelled(()=>{r(e)}),()=>{r(e)})})}unwrapOrElse(e){return new _({tag:"pending",execute:r=>(this.onResolved(a=>{r(a)}),this.onCancelled(()=>{r(e())}),()=>{r(e())})})}};c=new WeakMap,B=new WeakSet,$=function(e){if(n(this,c).tag==="pending"){let{resolve_callbacks:t}=n(this,c);E(this,c,{tag:"completed",value:e}),t==null||t.forEach(r=>r(e))}};var l,G,j,H,ee,b=class{constructor(e,t){g(this,G);g(this,H);g(this,l,void 0);E(this,l,e),t!=null&&t.lazy||this.then()}onResolved(e){var t;n(this,l).tag==="pending"?(n(this,l).resolve_callbacks=(t=n(this,l).resolve_callbacks)!=null?t:[],n(this,l).resolve_callbacks.push(e)):n(this,l).tag==="completed"&&e(n(this,l).value)}onSucceeded(e){this.onResolved(t=>{t.match({Ok:e,Error:()=>{}})})}onFailed(e){this.onResolved(t=>{t.match({Ok:()=>{},Error:e})})}onCancelled(e){var t;n(this,l).tag==="pending"?(n(this,l).cancel_callbacks=(t=n(this,l).cancel_callbacks)!=null?t:[],n(this,l).cancel_callbacks.push(e)):n(this,l).tag==="cancelled"&&e()}cancel(){if(n(this,l).tag==="pending"){let{cancel:e,cancel_callbacks:t}=n(this,l);E(this,l,{tag:"cancelled"}),e==null||e(),t==null||t.forEach(r=>r())}}then(e){if(n(this,l).tag==="pending"&&n(this,l).execute){let t=n(this,l).execute(K(this,G,j).bind(this),K(this,H,ee).bind(this));n(this,l).execute=null,t&&(n(this,l).cancel=t)}return e&&(this.onResolved(t=>e(h.Some(t))),this.onCancelled(()=>e(h.None()))),this}map(e){let t=F.makeFallible((r,a)=>(this.onResolved(O=>{O.match({Ok:s=>{r(e(s))},Error:a})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}mapError(e){let t=F.makeFallible((r,a)=>(this.onResolved(O=>{O.match({Ok:r,Error:s=>{a(e(s))}})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}andThen(e){let t=F.makeFallible((r,a)=>(this.onResolved(O=>{O.match({Ok:s=>{let y=F.fromFallible(e(s));y.onSucceeded(r),y.onFailed(a)},Error:a})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}orElse(e){let t=F.makeFallible((r,a)=>(this.onResolved(O=>{O.match({Ok:r,Error:s=>{let y=F.fromFallible(e(s));y.onSucceeded(r),y.onFailed(a)}})}),this.cancel.bind(this)));return this.onCancelled(t.cancel.bind(t)),t}tap(e){return this.onSucceeded(e),this}tapError(e){return this.onFailed(e),this}ok(){let e=F.make(t=>(this.onSucceeded(r=>t(h.Some(r))),this.onFailed(()=>t(h.None())),this.cancel.bind(this)));return this.onCancelled(e.cancel.bind(e)),e}unwrap(){let e=new _({tag:"pending",execute:t=>{this.onResolved(r=>t(r.unwrap()))}});return this.onCancelled(e.cancel.bind(e)),e}unwrapError(){let e=new _({tag:"pending",execute:t=>{this.onResolved(r=>t(r.unwrapError()))}});return this.onCancelled(e.cancel.bind(e)),e}unwrapOr(e){return new _({tag:"pending",execute:r=>(this.onResolved(a=>{r(a.unwrapOr(e))}),this.onCancelled(()=>{r(e)}),()=>{r(e)})})}unwrapOrElse(e){return new _({tag:"pending",execute:r=>(this.onResolved(a=>{r(a.unwrapOrElse(e))}),this.onCancelled(()=>{r(e())}),()=>{r(e())})})}match(e){let t=new _({tag:"pending",execute:r=>{this.onResolved(a=>{r(a.match(e))})}});return this.onCancelled(t.cancel.bind(t)),t}};l=new WeakMap,G=new WeakSet,j=function(e){if(n(this,l).tag==="pending"){let{resolve_callbacks:t}=n(this,l),r=d.Ok(e);E(this,l,{tag:"completed",value:r}),t==null||t.forEach(a=>a(r))}},H=new WeakSet,ee=function(e){if(n(this,l).tag==="pending"){let{resolve_callbacks:t}=n(this,l),r=d.Error(e);E(this,l,{tag:"completed",value:r}),t==null||t.forEach(a=>a(r))}};var p,k,L,te,_=class{constructor(e){g(this,L);g(this,p,void 0);g(this,k,void 0);if(E(this,p,e),n(this,p).tag==="pending"&&n(this,p).execute){let t=n(this,p).execute(K(this,L,te).bind(this));n(this,p).execute=null,t&&!n(this,k)&&E(this,k,t)}}onResolved(e){var t;n(this,p).tag==="pending"?(n(this,p).resolve_callbacks=(t=n(this,p).resolve_callbacks)!=null?t:[],n(this,p).resolve_callbacks.push(e)):n(this,p).tag==="completed"&&e(n(this,p).value)}onCancelled(e){n(this,p).tag==="pending"&&!n(this,k)?E(this,k,e):n(this,p).tag==="cancelled"&&!n(this,k)&&e(new Error("Cannot cancel UnwrappedFuture"))}cancel(){n(this,p).tag==="pending"&&(n(this,k)?(n(this,k).call(this,new Error("Cannot cancel UnwrappedFuture")),n(this,p).tag==="pending"&&E(this,p,{tag:"cancelled"})):E(this,p,{tag:"cancelled"}))}then(e,t){return e&&this.onResolved(e),t&&this.onCancelled(t),this}};p=new WeakMap,k=new WeakMap,L=new WeakSet,te=function(e){if(n(this,p).tag==="pending"){let{resolve_callbacks:t}=n(this,p);E(this,p,{tag:"completed",value:e}),t==null||t.forEach(r=>r(e))}};0&&(module.exports={Future,Option,Result});

package.json

 {
   "name": "@nobrayner/orf",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Option. Result. Future",
@@ -5,0 +5,0 @@ "sideEffect": false,

No alert changes

Improved metrics

Total package byte prevSize

70014

increased by0.34%

Lines of code

1426

increased by0.28%

No dependency changes