Page Menu
Home
c4science
Search
Configure Global Search
Log In
Files
F78394511
index.js
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Subscribers
None
File Metadata
Details
File Info
Storage
Attached
Created
Tue, Aug 20, 14:21
Size
1 KB
Mime Type
text/x-c++
Expires
Thu, Aug 22, 14:21 (2 d)
Engine
blob
Format
Raw Data
Handle
20036603
Attached To
rOACCT Open Access Compliance Check Tool (OACCT)
index.js
View Options
'use strict'
;
const
pLimit
=
require
(
'p-limit'
);
class
EndError
extends
Error
{
constructor
(
value
)
{
super
();
this
.
value
=
value
;
}
}
// The input can also be a promise, so we await it
const
testElement
=
async
(
element
,
tester
)
=>
tester
(
await
element
);
// The input can also be a promise, so we `Promise.all()` them both
const
finder
=
async
element
=>
{
const
values
=
await
Promise
.
all
(
element
);
if
(
values
[
1
]
===
true
)
{
throw
new
EndError
(
values
[
0
]);
}
return
false
;
};
const
pLocate
=
async
(
iterable
,
tester
,
options
)
=>
{
options
=
{
concurrency
:
Infinity
,
preserveOrder
:
true
,
...
options
};
const
limit
=
pLimit
(
options
.
concurrency
);
// Start all the promises concurrently with optional limit
const
items
=
[...
iterable
].
map
(
element
=>
[
element
,
limit
(
testElement
,
element
,
tester
)]);
// Check the promises either serially or concurrently
const
checkLimit
=
pLimit
(
options
.
preserveOrder
?
1
:
Infinity
);
try
{
await
Promise
.
all
(
items
.
map
(
element
=>
checkLimit
(
finder
,
element
)));
}
catch
(
error
)
{
if
(
error
instanceof
EndError
)
{
return
error
.
value
;
}
throw
error
;
}
};
module
.
exports
=
pLocate
;
Event Timeline
Log In to Comment