This is an automated email from the ASF dual-hosted git repository.
davin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/daffodil-vscode.git
The following commit(s) were added to refs/heads/main by this push:
new e00a9e4 Add inline comments to document 4K chunk used in Parse.run()
e00a9e4 is described below
commit e00a9e4a2bdb97ff23a06925f7d76c01c76d0df4
Author: Jeremy Yao <[email protected]>
AuthorDate: Fri Sep 12 14:18:19 2025 -0400
Add inline comments to document 4K chunk used in Parse.run()
Closes #712
---
debugger/src/main/scala/org.apache.daffodil.debugger.dap/Parse.scala | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/debugger/src/main/scala/org.apache.daffodil.debugger.dap/Parse.scala
b/debugger/src/main/scala/org.apache.daffodil.debugger.dap/Parse.scala
index cf6dd5b..6846390 100644
--- a/debugger/src/main/scala/org.apache.daffodil.debugger.dap/Parse.scala
+++ b/debugger/src/main/scala/org.apache.daffodil.debugger.dap/Parse.scala
@@ -95,9 +95,12 @@ object Parse {
done <- Ref[IO].of(false)
pleaseStop <- Deferred[IO, Unit]
} yield new Parse {
+ // Define run function associated w/ Parse instances
def run(): Stream[IO, Byte] =
+ // Note that .drain() and .through() being called on this do not
consume data
fs2.io
- .readOutputStream(4096) { os =>
+ .readOutputStream(4096) { os => // Sufficiently sized 4KB chunk size
for consumption process.
+
val stopper =
pleaseStop.get *> IO.canceled // will cancel the concurrent
parse effect