lib/celluloid/io/unix_socket.rb in celluloid-io-0.17.2 vs lib/celluloid/io/unix_socket.rb in celluloid-io-0.17.3

- old
+ new

@@ -2,44 +2,36 @@ module Celluloid module IO # UNIXSocket with combined blocking and evented support class UNIXSocket < Stream - extend Forwardable - - def_delegators :@socket, :read_nonblock, :write_nonblock, :close, :closed?, :readline, :puts, :addr - # Open a UNIX connection. def self.open(socket_path, &block) new(socket_path, &block) end # Convert a Ruby UNIXSocket into a Celluloid::IO::UNIXSocket # DEPRECATED: to be removed in a future release + # @deprecated use .new instead def self.from_ruby_socket(ruby_socket) new(ruby_socket) end # Open a UNIX connection. def initialize(socket_path, &block) - super() - # Allow users to pass in a Ruby UNIXSocket directly if socket_path.is_a? ::UNIXSocket - @socket = socket_path + super(socket_path) return end # FIXME: not doing non-blocking connect - @socket = if block - ::UNIXSocket.open(socket_path, &block) - else - ::UNIXSocket.new(socket_path) + if block + super ::UNIXSocket.open(socket_path, &block) + else + super ::UNIXSocket.new(socket_path) end end - def to_io - @socket - end end end end