Class: Kobako::Transport::Yielder

Inherits:
Object
  • Object
show all
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

Constructor Details

#initialize(yield_to_guest, break_tag) ⇒ 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.



40
41
42
43
44
 
# File 'lib/kobako/transport/yielder.rb', line 40

def initialize(yield_to_guest, break_tag)
  @yield_to_guest = yield_to_guest
  @break_tag = break_tag
  @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).



69
70
71
 
# File 'lib/kobako/transport/yielder.rb', line 69

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.



62
63
64
 
# File 'lib/kobako/transport/yielder.rb', line 62

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).

Raises:

  • (LocalJumpError) 


49
50
51
52
53
54
55
56
57
58
 
# File 'lib/kobako/transport/yielder.rb', line 49

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 response.value if response.ok?

  throw @break_tag, response.value if response.break?

  raise yield_failure(response.value, default: "yield error")
end