class MyStuff::Fb303::ResilientProcessor::SpyIProt

Public Class Methods

new(iprot) click to toggle source
# File lib/my_stuff/fb303/resilient_processor.rb, line 10
def initialize iprot
  @iprot = iprot
  @mode = :capture
end

Public Instance Methods

method_missing(*args) click to toggle source
# File lib/my_stuff/fb303/resilient_processor.rb, line 31
def method_missing *args
  @iprot.send *args
end
read_message_begin() click to toggle source
# File lib/my_stuff/fb303/resilient_processor.rb, line 15
def read_message_begin
  case @mode
  when :capture
    @header = @iprot.read_message_begin
    @mode = :replay
    @header
  when :replay
    @mode = :normal
    @header
  when :normal
    @iprot.read_message_begin
  else
    raise "Reached a bad state: %s" % @mode
  end
end