Class: Kobako::Transport::Yielder
- Inherits:
-
Object
- Object
- Kobako::Transport::Yielder
- Defined in:
- lib/kobako/transport/yielder.rb
Overview
Host-side stand-in for a guest-supplied block (B-23).
Each guest call that carries block_given: true gets a Yielder that the Dispatcher hands to the Service method as &block. The Service method observes it as an ordinary Ruby Proc through #to_proc; yield val / block.call(val) invokes #yield, which serialises the positional args, re-enters the guest via the injected yield_to_guest lambda (docs/behavior.md B-24), and reifies the YieldResponse into Ruby control flow:
* +tag 0x01+ ok — return the decoded value to +yield+'s caller
* +tag 0x02+ break — +throw break_tag, value+ so the Dispatcher's
+catch+ frame unwinds the Service method
({docs/behavior.md B-25}[link:../../../docs/behavior.md])
* +tag 0x04+ error — raise the +{class, message}+ payload at the
Service's yield site
The Dispatcher calls #invalidate! from its ensure block once dispatch completes; any later call to a stashed Yielder then raises LocalJumpError — the observable shape of docs/behavior.md E-23 (escaped Yielder).
Instance Method Summary collapse
-
#initialize(yield_to_guest, break_tag, handler) ⇒ Yielder
constructor
yield_to_guestis a String → String callable (typically Runtime#yield_to_active_invocation bound through a lambda) that #yield invokes to re-enter the guest;break_tagis thecatchthrow tag the Dispatcher matches against to unwind the Service on tag 0x02. -
#invalidate! ⇒ Object
Mark this Yielder dead.
-
#to_proc ⇒ Object
The Proc the Dispatcher passes as &block, binding #yield so a Service method’s
yield/block.calldrives the round-trip. -
#yield(*args) ⇒ Object
Re-enter the guest with
argsand reify the YieldResponse into Ruby control flow.
Constructor Details
#initialize(yield_to_guest, break_tag, handler) ⇒ Yielder
yield_to_guest is a String → String callable (typically Runtime#yield_to_active_invocation bound through a lambda) that #yield invokes to re-enter the guest; break_tag is the catch throw tag the Dispatcher matches against to unwind the Service on tag 0x02. handler is the Sandbox’s Kobako::Catalog::Handles, used to restore a Capability Handle in the block’s ok value back to its host object before it reaches the Service yield site (docs/behavior.md B-37).
43 44 45 46 47 48 |
# File 'lib/kobako/transport/yielder.rb', line 43 def initialize(yield_to_guest, break_tag, handler) @yield_to_guest = yield_to_guest @break_tag = break_tag @handler = handler @active = true end |
Instance Method Details
#invalidate! ⇒ Object
Mark this Yielder dead. Called by the Dispatcher’s ensure block when the originating dispatch frame returns; any later #yield call then raises LocalJumpError (E-23).
77 78 79 |
# File 'lib/kobako/transport/yielder.rb', line 77 def invalidate! @active = false end |
#to_proc ⇒ Object
The Proc the Dispatcher passes as &block, binding #yield so a Service method’s yield / block.call drives the round-trip.
70 71 72 |
# File 'lib/kobako/transport/yielder.rb', line 70 def to_proc method(:yield).to_proc end |
#yield(*args) ⇒ Object
Re-enter the guest with args and reify the YieldResponse into Ruby control flow. Raises LocalJumpError if called after #invalidate! (E-23). The ok value is consumed by the host Service method, so a Capability Handle in it is restored to its host object (B-37). The break value unwinds past the Service back to the guest Member call (B-25), so it passes through verbatim — a Handle stays a Handle and rides back on the same id rather than churning a new one.
57 58 59 60 61 62 63 64 65 66 |
# File 'lib/kobako/transport/yielder.rb', line 57 def yield(*args) raise LocalJumpError, "guest block invoked after host dispatch frame returned" unless @active response = Kobako::Transport::Yield.decode(@yield_to_guest.call(Kobako::Codec::Encoder.encode(args))) return restore(response.value) if response.ok? throw @break_tag, response.value if response.break? raise yield_failure(response.value, default: "yield error") end |