@@ -42,7 +42,46 @@ async function validateRead() {
4242 ) ;
4343}
4444
45+ async function validateReusedCreateReadStream ( ) {
46+ const filePath = path . resolve ( tmpDir , 'tmp-reused-stream.txt' ) ;
47+ fs . writeFileSync ( filePath , Buffer . from ( 'ab' , 'utf8' ) ) ;
48+
49+ const fileHandle = await open ( filePath , 'r' ) ;
50+ try {
51+ await buffer ( fileHandle . createReadStream ( {
52+ start : 0 ,
53+ end : 0 ,
54+ autoClose : false ,
55+ } ) ) ;
56+ assert . strictEqual ( fileHandle . listenerCount ( 'close' ) , 0 ) ;
57+
58+ await buffer ( fileHandle . createReadStream ( {
59+ start : 1 ,
60+ end : 1 ,
61+ autoClose : false ,
62+ } ) ) ;
63+ assert . strictEqual ( fileHandle . listenerCount ( 'close' ) , 0 ) ;
64+ } finally {
65+ await fileHandle . close ( ) ;
66+ }
67+ }
68+
69+ async function validateReusedCreateWriteStream ( ) {
70+ const filePath = path . resolve ( tmpDir , 'tmp-reused-write-stream.txt' ) ;
71+ const fileHandle = await open ( filePath , 'w' ) ;
72+ try {
73+ const stream = fileHandle . createWriteStream ( { autoClose : false } ) ;
74+ stream . end ( 'a' ) ;
75+ await finished ( stream ) ;
76+ assert . strictEqual ( fileHandle . listenerCount ( 'close' ) , 0 ) ;
77+ } finally {
78+ await fileHandle . close ( ) ;
79+ }
80+ }
81+
4582Promise . all ( [
4683 validateWrite ( ) ,
4784 validateRead ( ) ,
85+ validateReusedCreateReadStream ( ) ,
86+ validateReusedCreateWriteStream ( ) ,
4887] ) . then ( common . mustCall ( ) ) ;
0 commit comments