Contents

module RShade
  class TraceObservable
    include Observable
    attr_reader :trace_p
    CALL_EVENTS = Set[:call, :c_call, :b_call]
    RETURN_EVENTS = Set[:return, :c_return, :b_return]

    # @param [Enumerable<#call>, #call] observers
    # @param [::RShade::Config::Store] config
    def initialize(observers, config)
      @trace_p = TracePoint.new(*config.tp_events, &method(:process))
      observers = [observers] unless observers.is_a?(Enumerable)

      observers.each do |observer|
        add_observer(observer, :call)
      end
    end

    def reveal
      return unless block_given?

      trace_p.enable
      yield
      self
    ensure
      trace_p.disable
    end

    private
    # more info https://rubyapi.org/3.1/o/tracepoint
    # @param [TracePoint] tp
    def process(tp)
      changed
      event = Event.from_trace_point(tp)
      return notify_observers(event, :enter) if CALL_EVENTS.include?(tp.event)
      return notify_observers(event, :leave) if RETURN_EVENTS.include?(tp.event)
      notify_observers(event, :other)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rshade-0.1.9.1	lib/rshade/trace_observable.rb
rshade-0.1.9	lib/rshade/trace_observable.rb