Class: Procrastinate::IPC::Endpoint::Anonymous::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/procrastinate/ipc/endpoint.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(pipe) ⇒ Client

Returns a new instance of Client.



97
98
99
 
# File 'lib/procrastinate/ipc/endpoint.rb', line 97

def initialize(pipe)
  @pipe = pipe
end

Instance Attribute Details

#pipe ⇒ Object (readonly)

Returns the value of attribute pipe.



96
97
98
 
# File 'lib/procrastinate/ipc/endpoint.rb', line 96

def pipe
  @pipe
end

Instance Method Details

#send(msg) ⇒ Object 



101
102
103
104
 
# File 'lib/procrastinate/ipc/endpoint.rb', line 101

def send(msg)
  buffer = [msg.size].pack('l') + msg
  pipe.write(buffer)
end