Class: WebSocket::Driver
- Inherits:
-
Object
show all
- Includes:
- EventEmitter
- Defined in:
- lib/websocket/driver.rb,
lib/websocket/driver/hybi.rb,
lib/websocket/driver/proxy.rb,
lib/websocket/driver/client.rb,
lib/websocket/driver/server.rb,
lib/websocket/driver/draft75.rb,
lib/websocket/driver/draft76.rb,
lib/websocket/driver/headers.rb,
lib/websocket/driver/hybi/frame.rb,
lib/websocket/driver/hybi/message.rb,
lib/websocket/driver/event_emitter.rb,
lib/websocket/driver/hybi/stream_reader.rb
Defined Under Namespace
Modules: EventEmitter
Classes: Client, CloseEvent, ConnectEvent, Draft75, Draft76, Headers, Hybi, MessageEvent, OpenEvent, ProtocolError, Proxy, Server
Constant Summary
collapse
- MAX_LENGTH =
0x3ffffff
- STATES =
[:connecting, :open, :closing, :closed]
Instance Attribute Summary collapse
Instance Method Summary
collapse
#add_listener, #emit, #listener_count, #listeners, #on, #remove_all_listeners, #remove_listener
Constructor Details
#initialize(socket, options = {}) ⇒ Driver
Returns a new instance of Driver.
62
63
64
65
66
67
68
69
70
71
|
# File 'lib/websocket/driver.rb', line 62
def initialize(socket, options = {})
super()
@socket = socket
@options = options
@max_length = options[:max_length] || MAX_LENGTH
@headers = Headers.new
@queue = []
@ready_state = 0
end
|
Instance Attribute Details
#protocol ⇒ Object
Returns the value of attribute protocol.
60
61
62
|
# File 'lib/websocket/driver.rb', line 60
def protocol
@protocol
end
|
#ready_state ⇒ Object
Returns the value of attribute ready_state.
60
61
62
|
# File 'lib/websocket/driver.rb', line 60
def ready_state
@ready_state
end
|
Instance Method Details
#add_extension(extension) ⇒ Object
78
79
80
|
# File 'lib/websocket/driver.rb', line 78
def add_extension(extension)
false
end
|
#binary(message) ⇒ Object
99
100
101
|
# File 'lib/websocket/driver.rb', line 99
def binary(message)
false
end
|
#close(reason = nil, code = nil) ⇒ Object
107
108
109
110
111
112
|
# File 'lib/websocket/driver.rb', line 107
def close(reason = nil, code = nil)
return false unless @ready_state == 1
@ready_state = 3
emit(:close, CloseEvent.new(nil, nil))
true
end
|
#ping(*args) ⇒ Object
103
104
105
|
# File 'lib/websocket/driver.rb', line 103
def ping(*args)
false
end
|
82
83
84
85
86
|
# File 'lib/websocket/driver.rb', line 82
def (name, value)
return false unless @ready_state <= 0
@headers[name] = value
true
end
|
#start ⇒ Object
88
89
90
91
92
93
|
# File 'lib/websocket/driver.rb', line 88
def start
return false unless @ready_state == 0
@socket.write(Driver.encode(handshake_response, :binary))
open unless @stage == -1
true
end
|
#state ⇒ Object
73
74
75
76
|
# File 'lib/websocket/driver.rb', line 73
def state
return nil unless @ready_state >= 0
STATES[@ready_state]
end
|
#text(message) ⇒ Object
95
96
97
|
# File 'lib/websocket/driver.rb', line 95
def text(message)
frame(message)
end
|