Skip to content

Commit

Permalink
remove leftover debug calls
Browse files Browse the repository at this point in the history
  • Loading branch information
fwbrasil committed Dec 5, 2024
1 parent 5af826d commit 46d0553
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions kyo-prelude/shared/src/main/scala/kyo/Poll.scala
Original file line number Diff line number Diff line change
Expand Up @@ -250,27 +250,23 @@ object Poll:
ArrowEffect.handleFirst(emitTag, emit)(
handle = [C] =>
(emitted, emitCont) =>
// Debug.values(emitted)
// Once we have an emitted value, handle the first poll operation
// This creates the demand-driven cycle between emit and poll
ArrowEffect.handleFirst(pollTag, poll)(
handle = [C2] =>
(ack, pollCont) =>
// Debug.values(ack)
// Continue the emit-poll cycle:
// 1. Pass the ack back to emitter to control flow
// 2. Pass the emitted value to poller for consumption
// 3. Recursively continue the cycle
Loop.continue(emitCont(ack), pollCont(Maybe(emitted))),
// Poll.run(emitCont(ack))(pollCont(Maybe(emitted))),
done = b =>
// Debug.values(b)
// Poller completed early (e.g., received all needed values)
// Discard remaining emit operations
Emit.runDiscard(emitCont(Ack.Stop)).map(a => Loop.done((a, b)))
),
done = a =>
// Debug.values(a)
// Emitter completed (no more values to emit)
// Run remaining poll operations with empty chunk to signal completion
Poll.run(Chunk.empty)(poll).map(b => Loop.done((a, b)))
Expand Down

0 comments on commit 46d0553

Please sign in to comment.