1
1
import { makePromiseBuffer } from '../src/promisebuffer' ;
2
- import { makeSyncPromise } from '../src/syncpromise' ;
2
+ import { makePlatformPromise } from '../src/syncpromise' ;
3
3
4
4
describe ( 'PromiseBuffer' , ( ) => {
5
5
describe ( 'add()' , ( ) => {
6
6
test ( 'no limit' , ( ) => {
7
7
const buffer = makePromiseBuffer ( ) ;
8
- const p = jest . fn ( ( ) => makeSyncPromise ( resolve => setTimeout ( resolve ) ) ) ;
8
+ const p = jest . fn ( ( ) => makePlatformPromise ( resolve => setTimeout ( resolve ) ) ) ;
9
9
void buffer . add ( p ) ;
10
10
expect ( buffer . $ . length ) . toEqual ( 1 ) ;
11
11
} ) ;
@@ -14,10 +14,10 @@ describe('PromiseBuffer', () => {
14
14
const buffer = makePromiseBuffer ( 1 ) ;
15
15
let task1 ;
16
16
const producer1 = jest . fn ( ( ) => {
17
- task1 = makeSyncPromise ( resolve => setTimeout ( resolve ) ) ;
17
+ task1 = makePlatformPromise ( resolve => setTimeout ( resolve ) ) ;
18
18
return task1 ;
19
19
} ) ;
20
- const producer2 = jest . fn ( ( ) => makeSyncPromise ( resolve => setTimeout ( resolve ) ) ) ;
20
+ const producer2 = jest . fn ( ( ) => makePlatformPromise ( resolve => setTimeout ( resolve ) ) ) ;
21
21
expect ( buffer . add ( producer1 ) ) . toEqual ( task1 ) ;
22
22
void expect ( buffer . add ( producer2 ) ) . rejects . toThrowError ( ) ;
23
23
expect ( buffer . $ . length ) . toEqual ( 1 ) ;
@@ -30,7 +30,7 @@ describe('PromiseBuffer', () => {
30
30
test ( 'without timeout' , async ( ) => {
31
31
const buffer = makePromiseBuffer ( ) ;
32
32
for ( let i = 0 ; i < 5 ; i ++ ) {
33
- void buffer . add ( ( ) => makeSyncPromise ( resolve => setTimeout ( resolve ) ) ) ;
33
+ void buffer . add ( ( ) => makePlatformPromise ( resolve => setTimeout ( resolve ) ) ) ;
34
34
}
35
35
expect ( buffer . $ . length ) . toEqual ( 5 ) ;
36
36
const result = await buffer . drain ( ) ;
@@ -41,7 +41,7 @@ describe('PromiseBuffer', () => {
41
41
test ( 'with timeout' , async ( ) => {
42
42
const buffer = makePromiseBuffer ( ) ;
43
43
for ( let i = 0 ; i < 5 ; i ++ ) {
44
- void buffer . add ( ( ) => makeSyncPromise ( resolve => setTimeout ( resolve , 100 ) ) ) ;
44
+ void buffer . add ( ( ) => makePlatformPromise ( resolve => setTimeout ( resolve , 100 ) ) ) ;
45
45
}
46
46
expect ( buffer . $ . length ) . toEqual ( 5 ) ;
47
47
const result = await buffer . drain ( 50 ) ;
@@ -59,7 +59,7 @@ describe('PromiseBuffer', () => {
59
59
60
60
test ( 'resolved promises should not show up in buffer length' , async ( ) => {
61
61
const buffer = makePromiseBuffer ( ) ;
62
- const producer = ( ) => makeSyncPromise ( resolve => setTimeout ( resolve ) ) ;
62
+ const producer = ( ) => makePlatformPromise ( resolve => setTimeout ( resolve ) ) ;
63
63
const task = buffer . add ( producer ) ;
64
64
expect ( buffer . $ . length ) . toEqual ( 1 ) ;
65
65
await task ;
@@ -68,7 +68,7 @@ describe('PromiseBuffer', () => {
68
68
69
69
test ( 'rejected promises should not show up in buffer length' , async ( ) => {
70
70
const buffer = makePromiseBuffer ( ) ;
71
- const producer = ( ) => makeSyncPromise ( ( _ , reject ) => setTimeout ( reject ) ) ;
71
+ const producer = ( ) => makePlatformPromise ( ( _ , reject ) => setTimeout ( reject ) ) ;
72
72
const task = buffer . add ( producer ) ;
73
73
expect ( buffer . $ . length ) . toEqual ( 1 ) ;
74
74
try {
@@ -81,7 +81,7 @@ describe('PromiseBuffer', () => {
81
81
82
82
test ( 'resolved task should give an access to the return value' , async ( ) => {
83
83
const buffer = makePromiseBuffer < string > ( ) ;
84
- const producer = ( ) => makeSyncPromise < string > ( resolve => setTimeout ( ( ) => resolve ( 'test' ) ) ) ;
84
+ const producer = ( ) => makePlatformPromise < string > ( resolve => setTimeout ( ( ) => resolve ( 'test' ) ) ) ;
85
85
const task = buffer . add ( producer ) ;
86
86
const result = await task ;
87
87
expect ( result ) . toEqual ( 'test' ) ;
@@ -90,7 +90,7 @@ describe('PromiseBuffer', () => {
90
90
test ( 'rejected task should give an access to the return value' , async ( ) => {
91
91
expect . assertions ( 1 ) ;
92
92
const buffer = makePromiseBuffer < string > ( ) ;
93
- const producer = ( ) => makeSyncPromise < string > ( ( _ , reject ) => setTimeout ( ( ) => reject ( new Error ( 'whoops' ) ) ) ) ;
93
+ const producer = ( ) => makePlatformPromise < string > ( ( _ , reject ) => setTimeout ( ( ) => reject ( new Error ( 'whoops' ) ) ) ) ;
94
94
const task = buffer . add ( producer ) ;
95
95
try {
96
96
await task ;
0 commit comments