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
 

Reply via email to