1
1
import { itBench } from '@dapplion/benchmark'
2
2
import { abortableSource } from 'abortable-iterator'
3
- import { pipe , Transform } from 'it-pipe'
4
3
import all from 'it-all'
4
+ import { pipe } from 'it-pipe'
5
5
6
6
/* eslint-disable generator-star-spacing */
7
7
@@ -10,7 +10,7 @@ describe('abortableSource cost', function () {
10
10
const bytes = new Uint8Array ( 200 )
11
11
const controller = new AbortController ( )
12
12
13
- async function * bytesSource ( ) {
13
+ async function * bytesSource ( ) : AsyncGenerator < Uint8Array , void , unknown > {
14
14
let i = 0
15
15
while ( i ++ < n ) {
16
16
yield bytes
@@ -29,7 +29,7 @@ describe('abortableSource cost', function () {
29
29
} ,
30
30
fn : async ( source ) => {
31
31
for await ( const chunk of source ) {
32
- // eslint-disable-next-line no-unused-expressions
32
+ // eslint-disable-next-line @typescript-eslint/ no-unused-expressions
33
33
chunk
34
34
}
35
35
}
@@ -40,14 +40,14 @@ describe('abortableSource cost', function () {
40
40
describe ( 'pipe extra iterables cost' , function ( ) {
41
41
const n = 10000
42
42
43
- async function * numberSource ( ) {
43
+ async function * numberSource ( ) : AsyncGenerator < number , void , unknown > {
44
44
let i = 0
45
45
while ( i < n ) {
46
46
yield i ++
47
47
}
48
48
}
49
49
50
- async function * numberTransform ( source : AsyncIterable < number > ) : AsyncIterable < number > {
50
+ async function * numberTransform ( source : AsyncIterable < number > ) : AsyncIterable < number > {
51
51
for await ( const num of source ) {
52
52
yield num + 1
53
53
}
@@ -63,7 +63,7 @@ describe('pipe extra iterables cost', function () {
63
63
itBench ( {
64
64
id : `async iterate pipe x1 transforms ${ n } ` ,
65
65
fn : async ( ) => {
66
- await pipe ( numberSource , numberTransform as Transform < number , number > , all )
66
+ await pipe ( numberSource , numberTransform , all )
67
67
}
68
68
} )
69
69
@@ -72,8 +72,8 @@ describe('pipe extra iterables cost', function () {
72
72
fn : async ( ) => {
73
73
await pipe (
74
74
numberSource ,
75
- numberTransform as Transform < number , number > ,
76
- numberTransform as Transform < number , number > ,
75
+ numberTransform ,
76
+ numberTransform ,
77
77
all
78
78
)
79
79
}
@@ -84,10 +84,10 @@ describe('pipe extra iterables cost', function () {
84
84
fn : async ( ) => {
85
85
await pipe (
86
86
numberSource ,
87
- numberTransform as Transform < number , number > ,
88
- numberTransform as Transform < number , number > ,
89
- numberTransform as Transform < number , number > ,
90
- numberTransform as Transform < number , number > ,
87
+ numberTransform ,
88
+ numberTransform ,
89
+ numberTransform ,
90
+ numberTransform ,
91
91
all
92
92
)
93
93
}
@@ -98,14 +98,14 @@ describe('pipe extra iterables cost', function () {
98
98
fn : async ( ) => {
99
99
await pipe (
100
100
numberSource ,
101
- numberTransform as Transform < number , number > ,
102
- numberTransform as Transform < number , number > ,
103
- numberTransform as Transform < number , number > ,
104
- numberTransform as Transform < number , number > ,
105
- numberTransform as Transform < number , number > ,
106
- numberTransform as Transform < number , number > ,
107
- numberTransform as Transform < number , number > ,
108
- numberTransform as Transform < number , number > ,
101
+ numberTransform ,
102
+ numberTransform ,
103
+ numberTransform ,
104
+ numberTransform ,
105
+ numberTransform ,
106
+ numberTransform ,
107
+ numberTransform ,
108
+ numberTransform ,
109
109
all
110
110
)
111
111
}
0 commit comments