@@ -616,7 +616,7 @@ export default class Helpers {
616
616
let chunkBytes = 0
617
617
timeoutRef = setTimeout ( onFlushTimeout , flushInterval ) // eslint-disable-line
618
618
619
- // @ts -expect-error datasoruce is an iterable
619
+ // @ts -expect-error datasource is an iterable
620
620
for await ( const chunk of datasource ) {
621
621
if ( shouldAbort ) break
622
622
timeoutRef . refresh ( )
@@ -657,7 +657,7 @@ export default class Helpers {
657
657
}
658
658
659
659
clearTimeout ( timeoutRef )
660
- // In some cases the previos http call does not have finished,
660
+ // In some cases the previous http call has not finished,
661
661
// or we didn't reach the flush bytes threshold, so we force one last operation.
662
662
if ( ! shouldAbort && chunkBytes > 0 ) {
663
663
const send = await semaphore ( )
@@ -701,8 +701,8 @@ export default class Helpers {
701
701
// to guarantee that no more than the number of operations
702
702
// allowed to run at the same time are executed.
703
703
// It returns a semaphore function which resolves in the next tick
704
- // if we didn't reach the maximim concurrency yet, otherwise it returns
705
- // a promise that resolves as soon as one of the running request has finshed .
704
+ // if we didn't reach the maximum concurrency yet, otherwise it returns
705
+ // a promise that resolves as soon as one of the running requests has finished .
706
706
// The semaphore function resolves a send function, which will be used
707
707
// to send the actual bulk request.
708
708
// It also returns a finish function, which returns a promise that is resolved
0 commit comments