# frozen_string_literal: false

[0] Fix | Delete

require 'observer'

[1] Fix | Delete

[2] Fix | Delete

module DRb

[3] Fix | Delete

# The Observable module extended to DRb. See Observable for details.

[4] Fix | Delete

module DRbObservable

[5] Fix | Delete

include Observable

[6] Fix | Delete

[7] Fix | Delete

# Notifies observers of a change in state. See also

[8] Fix | Delete

# Observable#notify_observers

[9] Fix | Delete

def notify_observers(*arg)

[10] Fix | Delete

if defined? @observer_state and @observer_state

[11] Fix | Delete

if defined? @observer_peers

[12] Fix | Delete

@observer_peers.each do |observer, method|

[13] Fix | Delete

begin

[14] Fix | Delete

observer.send(method, *arg)

[15] Fix | Delete

rescue

[16] Fix | Delete

delete_observer(observer)

[17] Fix | Delete

end

[18] Fix | Delete

end

[19] Fix | Delete

end

[20] Fix | Delete

@observer_state = false

[21] Fix | Delete

end

[22] Fix | Delete

end

[23] Fix | Delete

end

[24] Fix | Delete

end

[25] Fix | Delete

[26] Fix | Delete