Class: Celluloid::IO::RackSocket

Inherits:
Stream
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/celluloid/io/rack_socket.rb

Overview

Wraps a socket as gotten from the Rack hijack API

Instance Method Summary collapse

Constructor Details

#initialize(socket) ⇒ RackSocket

Returns a new instance of RackSocket.



12
13
14
15
 
# File 'lib/celluloid/io/rack_socket.rb', line 12

def initialize(socket)
  super()
  @socket = socket
end

Instance Method Details

#readpartial(bufsize) ⇒ Object 



21
22
23
24
 
# File 'lib/celluloid/io/rack_socket.rb', line 21

def readpartial(bufsize)
  result = super(bufsize)
  result
end

#recv(maxlen, flags = nil) ⇒ Object

Receives a message

Raises:

  • (NotImplementedError) 


27
28
29
30
 
# File 'lib/celluloid/io/rack_socket.rb', line 27

def recv(maxlen, flags=nil)
  raise NotImplementedError, "flags not supported" if flags && !flags.zero?
  readpartial(maxlen)
end

#send(msg, flags, dest_sockaddr = nil) ⇒ Object

Send a message

Raises:

  • (NotImplementedError) 


33
34
35
36
37
 
# File 'lib/celluloid/io/rack_socket.rb', line 33

def send(msg, flags, dest_sockaddr = nil)
  raise NotImplementedError, "dest_sockaddr not supported" if dest_sockaddr
  raise NotImplementedError, "flags not supported" unless flags.zero?
  write(msg)
end

#to_io ⇒ Object 



17
18
19
 
# File 'lib/celluloid/io/rack_socket.rb', line 17

def to_io
  @socket
end