Class: Tribe::EM::ActorProxy

Inherits:
EM::Connection
  • Object
show all
Defined in:
lib/tribe_em/actor_proxy.rb

Instance Method Summary collapse

Instance Method Details

#close(after_writing = false) ⇒ Object



41
42
43
44
45
# File 'lib/tribe_em/actor_proxy.rb', line 41

def close(after_writing = false)
  ::EM.schedule { close_connection(after_writing) }

  return nil
end

#post_initObject



23
24
25
# File 'lib/tribe_em/actor_proxy.rb', line 23

def post_init
  @actor.message!(:post_init, nil)
end

#receive_data(data) ⇒ Object



27
28
29
# File 'lib/tribe_em/actor_proxy.rb', line 27

def receive_data(data)
  @actor.message!(:receive_data, data)
end

#unbindObject



31
32
33
# File 'lib/tribe_em/actor_proxy.rb', line 31

def unbind
  @actor.message!(:unbind, nil)
end

#write(data) ⇒ Object



47
48
49
50
51
# File 'lib/tribe_em/actor_proxy.rb', line 47

def write(data)
  ::EM.schedule { send_data(data) }

  return nil
end