1
1
package io .scalajs .nodejs .fs
2
2
3
+ import io .scalajs .JSON
3
4
import io .scalajs .nodejs .setImmediate
4
5
import io .scalajs .nodejs .util .Util
6
+ import io .scalajs .util .ScalaJsHelper ._
5
7
import org .scalatest .FunSpec
6
8
7
9
import scala .scalajs .js
@@ -15,12 +17,16 @@ class FsTest extends FunSpec {
15
17
describe(" Fs" ) {
16
18
17
19
it(" supports watching files" ) {
18
- val watcher = Fs .watch(" ./src/test/resources/" , (value : js. Any ) => {
19
- info(s " watcher value: ${ Util .inspect(value)} " )
20
+ val watcher = Fs .watch(" ./src/test/resources/" , (eventType, file ) => {
21
+ info(s " watcher: eventType = ' $eventType ' file = ' $file ' " )
20
22
})
21
23
info(s " watcher: ${Util .inspect(watcher)}" )
22
24
23
- setImmediate(() => Fs .writeFile(" ./src/test/resources/1.txt" , " Hello" , () => {}))
25
+ setImmediate(() => Fs .writeFile(" ./src/test/resources/1.txt" , " Hello" , error => {
26
+ if (isDefined(error)) {
27
+ alert(s " error: ${JSON .stringify(error)}" )
28
+ }
29
+ }))
24
30
}
25
31
26
32
it(" should stream data" ) {
@@ -31,7 +37,7 @@ class FsTest extends FunSpec {
31
37
val readable = Fs .createReadStream(file1)
32
38
val writable = Fs .createWriteStream(file2)
33
39
readable.setEncoding(" utf8" )
34
- readable.onData(chunk => writable.write(chunk))
40
+ readable.onData[ String ] (chunk => writable.write(chunk))
35
41
writable.onFinish { () =>
36
42
info(" Comparing file sizes:" )
37
43
info(s " $file1 is ${Fs .statSync(file1).size} bytes " )
0 commit comments