Comparing version 0.19.0-dev.3 to 0.19.0-dev.4
@@ -25,10 +25,10 @@ Object.defineProperty(exports,"packageName",{enumerable:!0,get:function(){return _package.name}}) | ||
const evalReadlineExtend=async(e,r,t)=>{const{onLineSync:o,getResult:s,logLineInterval:a=0}=e | ||
const n=(0,_time.clock)() | ||
let i=0 | ||
let c="" | ||
const l=a?()=>i%a==0&&t(`line: ${(0,_format.decimal)(i)} (+${(0,_format.time)((0,_time.clock)()-n)})`):()=>{} | ||
await(0,_function2.createReadlineFromFileAsync)(r,e=>{c=e | ||
let n=0 | ||
let i="" | ||
const c=a&&(0,_time.createStepper)() | ||
const l=a?()=>n%a==0&&t(`line: ${(0,_format.decimal)(n)} (+${(0,_format.time)(c())})`):()=>{} | ||
await(0,_function2.createReadlineFromFileAsync)(r,e=>{i=e | ||
l() | ||
o(c,i) | ||
i++}) | ||
o(i,n) | ||
n++}) | ||
return s()} | ||
@@ -35,0 +35,0 @@ exports.evalReadlineExtend=evalReadlineExtend |
@@ -1,51 +0,52 @@ | ||
var t=require("./time") | ||
var e=require("./error") | ||
const r=(t,e=250,r=!1)=>{let o=null | ||
return(...s)=>{const n=r&&null===o | ||
var e=require("./time") | ||
var t=require("./error") | ||
const r=(e,t=250,r=!1)=>{let o=null | ||
return(...s)=>{const i=r&&null===o | ||
clearTimeout(o) | ||
o=setTimeout(()=>{o=null | ||
!r&&t.apply(null,s)},e) | ||
n&&t.apply(null,s)}} | ||
!r&&e.apply(null,s)},t) | ||
i&&e.apply(null,s)}} | ||
exports.debounce=r | ||
exports.throttle=((t,e=250,r=!1)=>{let o=null | ||
exports.throttle=((e,t=250,r=!1)=>{let o=null | ||
return(...s)=>{if(o)return | ||
const n=r&&null===o | ||
const i=r&&null===o | ||
o=setTimeout(()=>{o=null | ||
!r&&t.apply(null,s)},e) | ||
n&&t.apply(null,s)}}) | ||
exports.lossyAsync=((t,r=e.rethrowError)=>{let o | ||
!r&&e.apply(null,s)},t) | ||
i&&e.apply(null,s)}}) | ||
exports.lossyAsync=((e,r=t.rethrowError)=>{let o | ||
const s=()=>{o=void 0} | ||
const n=t=>{o=void 0 | ||
r(t)} | ||
return{trigger:(...e)=>{if(!o)try{const r=t.apply(null,e) | ||
r instanceof Object&&r.then?o=r.then(s,n):s()}catch(t){n(t)}},getRunningPromise:()=>o}}) | ||
exports.withDelayArgvQueue=((t,e=r,...o)=>{let s=[] | ||
const n=e(()=>{const e=s | ||
const i=e=>{o=void 0 | ||
r(e)} | ||
return{trigger:(...t)=>{if(!o)try{const r=e.apply(null,t) | ||
r instanceof Object&&r.then?o=r.then(s,i):s()}catch(e){i(e)}},getRunningPromise:()=>o}}) | ||
exports.withDelayArgvQueue=((e,t=r,...o)=>{let s=[] | ||
const i=t(()=>{const t=s | ||
s=[] | ||
t(e)},...o) | ||
return(...t)=>{s.push(t) | ||
n()}}) | ||
exports.withRepeat=((t,e=0)=>{let r=0 | ||
for(;e>r;){t(r,e) | ||
e(t)},...o) | ||
return(...e)=>{s.push(e) | ||
i()}}) | ||
exports.withRepeat=((e,t=0)=>{let r=0 | ||
for(;t>r;){e(r,t) | ||
r++}}) | ||
exports.withRepeatAsync=(async(e,r=0,o=0)=>{let s=0 | ||
for(;r>s;){const n=(0,t.clock)() | ||
await e(s,r) | ||
exports.withRepeatAsync=(async(t,r=0,o=0)=>{let s=0 | ||
for(;r>s;){const i=(0,e.clock)() | ||
await t(s,r) | ||
s++ | ||
const i=o-((0,t.clock)()-n) | ||
i>0&&await(0,t.setTimeoutAsync)(i)}}) | ||
exports.withRetry=((t,e=1/0)=>{let r=0 | ||
for(;;)try{return t(r,e)}catch(t){if(e<++r)throw t}}) | ||
exports.withRetryAsync=(async(e,r=1/0,o=0)=>{let s=0 | ||
for(;;){const n=(0,t.clock)() | ||
try{return await e(s,r)}catch(e){if(r<++s)throw e | ||
const i=o-((0,t.clock)()-n) | ||
i>0&&await(0,t.setTimeoutAsync)(i)}}}) | ||
exports.withPromiseTimeout=((t,e)=>Promise.race([t,new Promise((t,r)=>setTimeout(()=>r(new Error(`[withPromiseTimeout] timeout after: ${e}`)),e))])) | ||
exports.createInsideOutPromise=(()=>{let t,e | ||
return{promise:new Promise((r,o)=>{t=r | ||
e=o}),resolve:r=>{const o=t | ||
t=e=void 0 | ||
o&&o(r)},reject:r=>{const o=e | ||
t=e=void 0 | ||
const n=o-((0,e.clock)()-i) | ||
n>0&&await(0,e.setTimeoutAsync)(n)}}) | ||
exports.withRetry=((e,t=1/0)=>{let r=0 | ||
for(;;)try{return e(r,t)}catch(e){if(t<++r)throw e}}) | ||
exports.withRetryAsync=(async(t,r=1/0,o=0)=>{let s=0 | ||
for(;;){const i=(0,e.clock)() | ||
try{return await t(s,r)}catch(t){if(r<++s)throw t | ||
const n=o-((0,e.clock)()-i) | ||
n>0&&await(0,e.setTimeoutAsync)(n)}}}) | ||
exports.withTimeoutAsync=((e,t)=>Promise.race([e(),new Promise((e,r)=>setTimeout(()=>r(new Error(`[withTimeoutAsync] timeout after: ${t}`)),t))])) | ||
exports.withTimeoutPromise=((e,t)=>Promise.race([e,new Promise((e,r)=>setTimeout(()=>r(new Error(`[withTimeoutPromise] timeout after: ${t}`)),t))])) | ||
exports.createInsideOutPromise=(()=>{let e,t | ||
return{promise:new Promise((r,o)=>{e=r | ||
t=o}),resolve:r=>{const o=e | ||
e=t=void 0 | ||
o&&o(r)},reject:r=>{const o=t | ||
e=t=void 0 | ||
o&&o(r)}}}) |
@@ -21,1 +21,5 @@ var e=require("../env/global") | ||
s=null}},isActive:()=>Boolean(s)}}) | ||
exports.createStepper=((e=t())=>()=>{const r=t() | ||
const o=r-e | ||
e=r | ||
return o}) |
@@ -40,3 +40,2 @@ Object.defineProperty(exports,"createReadStream",{enumerable:!0,get:function(){return r.createReadStream}}) | ||
const b=/\\/g | ||
const v="\\"===e.sep?e=>e.replace(b,"/"):e=>e | ||
exports.toPosixPath=v | ||
exports.toPosixPath=(e=>e.replace(b,"/")) |
@@ -98,3 +98,4 @@ import { clock, setTimeoutAsync } from "./time"; | ||
}; | ||
const withPromiseTimeout = (promise, timeout) => Promise.race([ promise, new Promise((resolve, reject) => setTimeout(() => reject(new Error(`[withPromiseTimeout] timeout after: ${timeout}`)), timeout)) ]); | ||
const withTimeoutAsync = (func, timeout) => Promise.race([ func(), new Promise((resolve, reject) => setTimeout(() => reject(new Error(`[withTimeoutAsync] timeout after: ${timeout}`)), timeout)) ]); | ||
const withTimeoutPromise = (promise, timeout) => Promise.race([ promise, new Promise((resolve, reject) => setTimeout(() => reject(new Error(`[withTimeoutPromise] timeout after: ${timeout}`)), timeout)) ]); | ||
const createInsideOutPromise = () => { | ||
@@ -119,2 +120,2 @@ let promiseResolve, promiseReject; | ||
}; | ||
export { debounce, throttle, lossyAsync, withDelayArgvQueue, withRepeat, withRepeatAsync, withRetry, withRetryAsync, withPromiseTimeout, createInsideOutPromise }; | ||
export { debounce, throttle, lossyAsync, withDelayArgvQueue, withRepeat, withRepeatAsync, withRetry, withRetryAsync, withTimeoutAsync, withTimeoutPromise, createInsideOutPromise }; |
@@ -44,2 +44,8 @@ import { global } from "../env/global"; | ||
}; | ||
export { CLOCK_PER_SECOND, CLOCK_TO_SECOND, clock, getTimestamp, setTimeoutAsync, requestFrameUpdate, cancelFrameUpdate, createTimer }; | ||
const createStepper = (prevTime = clock()) => () => { | ||
const nextTime = clock(); | ||
const result = nextTime - prevTime; | ||
prevTime = nextTime; | ||
return result; | ||
}; | ||
export { CLOCK_PER_SECOND, CLOCK_TO_SECOND, clock, getTimestamp, setTimeoutAsync, requestFrameUpdate, cancelFrameUpdate, createTimer, createStepper }; |
@@ -39,3 +39,3 @@ import { resolve as resolvePath, normalize, dirname, sep } from "path"; | ||
const REGEXP_PATH_SEP_WIN32 = /\\/g; | ||
const toPosixPath = "\\" === sep ? path => path.replace(REGEXP_PATH_SEP_WIN32, "/") : path => path; | ||
const toPosixPath = path => path.replace(REGEXP_PATH_SEP_WIN32, "/"); | ||
export { createReadStream, createWriteStream, statAsync, openAsync, renameAsync, unlinkAsync, truncateAsync, readFileAsync, writeFileAsync, appendFileAsync, copyFileAsync, mkdirAsync, rmdirAsync, readdirAsync, visibleAsync, readableAsync, writableAsync, executableAsync, nearestExistAsync, createPathPrefixLock, createReadlineFromStreamAsync, createReadlineFromFileAsync, trimPathDepth, toPosixPath }; |
@@ -1,1 +0,1 @@ | ||
{"name":"dr-js","version":"0.19.0-dev.3","description":"A collection of strange functions","author":"dr-js","license":"MIT","keywords":["Dr","Dr-js","JavaScript"],"repository":"github:dr-js/dr-js","bin":"bin/index.js","browser":"library/Dr.browser.js","engines":{"node":">=8.12","npm":">=6"},"sideEffects":false} | ||
{"name":"dr-js","version":"0.19.0-dev.4","description":"A collection of strange functions","author":"dr-js","license":"MIT","keywords":["Dr","Dr-js","JavaScript"],"repository":"github:dr-js/dr-js","bin":"bin/index.js","browser":"library/Dr.browser.js","engines":{"node":">=8.12","npm":">=6"},"sideEffects":false} |
Sorry, the diff of this file is too big to display
454969
10504