@nobrayner/orf - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

lib/orf.d.ts

@@ -1061,8 +1061,39 @@ interface IResult<T, E> {
   function all<A extends Array<Future<any> | FallibleFuture<any, any>>>(array: [...A]): FallibleFuture<{ [K in keyof A]: A[K] extends FallibleFuture<infer U, infer _> ? U : A[K] extends Future<infer U> ? U : never }, orf.InferErrorType<A[number]>>;
+  /**
+   * Creates a new `Future` that resolves to a tuple of the passed fallible future's
+   * resolved `Result` values. Similiar to `Promise.allSettled`
+   *
+   * ## Example
+   * ```ts
+   * const result = await Future.all([Future.success(1), Future.success("hi")]);
+   * // result === Option.Some([Result.Ok(1), Result.Ok("hi")]))
+   *
+   * const result = await Future.all([
+   *   Future.success(1),
+   *   Future.fail("error1"),
+   *   Future.fail("error2"),
+   *]);
+   * // result === Option.Some([
+   *   Result.Ok(1),
+   *   Result.Error("error1"),
+   *   Result.Error("error2"),
+   * ])
+   *```
+   */
+  function allResolved<A extends Array<FallibleFuture<any, any>>>(array: [...A]): Future<{ [K in keyof A]: Result<orf.InferOkType<A[K]>, orf.InferErrorType<A[K]>> }>;
+  /**
+   * Similar to `Future.all`, but for a dictionary of `Fallible Future`s
+   */
   function allFromDict<D extends {
     [K: PropertyKey]: FallibleFuture<any, any>;
   }>(dict: D): FallibleFuture<{ [K in keyof D]: orf.InferOkType<D[K]> }, orf.InferErrorType<D[keyof D]>>;
+  /**
+   * Similar to `Future.all`, but for a dictionary of `Future`s
+   */
   function allFromDict<D extends {
     [K: PropertyKey]: Future<any>;
   }>(dict: D): Future<{ [K in keyof D]: D[K] extends Future<infer U> ? U : never }>;
+  /**
+   * Similar to `Future.all`, but for a dictionary of `Future`s or `Fallible Future`s.
+   */
   function allFromDict<D extends {
@@ -1069,0 +1100,0 @@ [K: PropertyKey]: Future<any> | FallibleFuture<any, any>;

lib/orf.js

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

package.json

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

No alert changes

Improved metrics

Total package byte prevSize

73430

increased by2.11%

Lines of code

1564

increased by2.16%

No dependency changes