diff --git a/internal/js/reader.go b/internal/js/reader.go
index 384b361..f1d14f7 100644
--- a/internal/js/reader.go
+++ b/internal/js/reader.go
@@ -20,6 +20,7 @@ type ChannelReader struct {
 func NewChannelReader(source <-chan []byte, cancelFn context.CancelFunc) *ChannelReader {
 	return &ChannelReader{
 		source: source,
+		cancelFn: cancelFn,
 	}
 }