Skip to content

Commit 0f3b427

Browse files
committed
forward errors inside internal 'destroy' method;
1 parent e132270 commit 0f3b427

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

test/test_lib/StreamTestLib.re

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ let makeReadableEmpty = () => {
44
let options =
55
makeOptions(
66
~destroy=
7-
[@bs.this] (_, err, done_) => done_(~err=Js.Nullable.toOption(err)),
8-
~read=[@bs.this] (_, _) => (),
7+
[@bs.this] (_, err, done_) => {done_(~err=Js.Nullable.toOption(err));},
8+
~read=[@bs.this] (_, _size) => (),
99
~autoDestroy=true,
1010
(),
1111
);
@@ -17,7 +17,7 @@ let makeWritableEmpty = () => {
1717
open Stream.Writable;
1818
let options =
1919
makeOptions(
20-
~destroy=[@bs.this] (_, _, done_) => {done_(~err=None)},
20+
~destroy=[@bs.this] (_, err, done_) => {done_(~err=Js.Nullable.toOption(err));},
2121
~write=[@bs.this] (_, _, _) => (),
2222
~autoDestroy=true,
2323
(),

0 commit comments

Comments
 (0)