Class: Faye::WebSocket::Stream

Inherits:

Object

• Object
• Faye::WebSocket::Stream

Extended by:

Forwardable

Includes:

EventMachine::Deferrable

Defined in:

lib/faye/util/web_socket.rb

Instance Method Summary

• #each(&callback) ⇒ Object
• #fail ⇒ Object
• #initialize(web_socket, connection) ⇒ Stream constructor

  A new instance of Stream.

• #write(data) ⇒ Object

Constructor Details

#initialize(web_socket, connection) ⇒ Stream

Returns a new instance of Stream.

# File 'lib/faye/util/web_socket.rb', line 70

def initialize(web_socket, connection)
  @web_socket = web_socket
  @connection = connection
end

Instance Method Details

#each(&callback) ⇒ Object

# File 'lib/faye/util/web_socket.rb', line 75

def each(&callback)
  @data_callback = callback
end

#fail ⇒ Object

# File 'lib/faye/util/web_socket.rb', line 79

def fail
  @web_socket.close(1006, '', false)
end

#write(data) ⇒ Object

# File 'lib/faye/util/web_socket.rb', line 83

def write(data)
  return unless @data_callback
  @data_callback.call(data)
end