Class: WebSocket::Driver
- Inherits:
-
Object
show all
- Includes:
- EventEmitter
- Defined in:
- lib/websocket/driver.rb,
lib/websocket/driver/hybi.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/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, Server
Constant Summary
collapse
- 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.
58
59
60
61
62
63
64
65
66
|
# File 'lib/websocket/driver.rb', line 58
def initialize(socket, options = {})
super()
@socket = socket
@options = options
@headers = Headers.new
@queue = []
@ready_state = 0
end
|
Instance Attribute Details
#protocol ⇒ Object
Returns the value of attribute protocol.
56
57
58
|
# File 'lib/websocket/driver.rb', line 56
def protocol
@protocol
end
|
#ready_state ⇒ Object
Returns the value of attribute ready_state.
56
57
58
|
# File 'lib/websocket/driver.rb', line 56
def ready_state
@ready_state
end
|
Instance Method Details
#binary(message) ⇒ Object
90
91
92
|
# File 'lib/websocket/driver.rb', line 90
def binary(message)
false
end
|
#close(reason = nil, code = nil) ⇒ Object
98
99
100
101
102
103
|
# File 'lib/websocket/driver.rb', line 98
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
94
95
96
|
# File 'lib/websocket/driver.rb', line 94
def ping(*args)
false
end
|
73
74
75
76
77
|
# File 'lib/websocket/driver.rb', line 73
def (name, value)
return false unless @ready_state <= 0
@headers[name] = value
true
end
|
#start ⇒ Object
79
80
81
82
83
84
|
# File 'lib/websocket/driver.rb', line 79
def start
return false unless @ready_state == 0
@socket.write(Driver.encode(handshake_response, :binary))
open unless @stage == -1
true
end
|
#state ⇒ Object
68
69
70
71
|
# File 'lib/websocket/driver.rb', line 68
def state
return nil unless @ready_state >= 0
STATES[@ready_state]
end
|
#text(message) ⇒ Object
86
87
88
|
# File 'lib/websocket/driver.rb', line 86
def text(message)
frame(message)
end
|