Module DRb::Observable
In: lib/drb/observable.rb

Methods

Included Modules

::Observable

Public Instance methods

[Source]

# File lib/drb/observable.rb, line 35
    def notify_observer(observer, *arg, &block)
      if defined? @observer_state and @observer_state
        if defined? @observer_peers
          if @observer_peers.include?(observer)
            begin
              observer.update(*arg, &block)
            rescue
              delete_observer(observer)
            end
          end
        end
        @observer_state = false
      end
    end

[Source]

# File lib/drb/observable.rb, line 20
    def notify_observers(*args, &block)
      if defined? @observer_state and @observer_state
        if defined? @observer_peers
          for i in @observer_peers.dup
            begin
              i.update(*args, &block)
            rescue
              delete_observer(i)
            end
          end
        end
        @observer_state = false
      end
    end

[Validate]