Class: Channel
Instance Attribute Summary collapse
Instance Method Summary
collapse
included, #reactive_method_tag
Constructor Details
Returns a new instance of Channel.
11
12
13
14
15
16
17
18
19
20
|
# File 'lib/volt/page/channel.rb', line 11
def initialize
@socket = nil
@status = :opening
@connected = false
@error = nil
@retry_count = 0
@queue = []
connect!
end
|
Instance Attribute Details
Returns the value of attribute error.
9
10
11
|
# File 'lib/volt/page/channel.rb', line 9
def error
@error
end
|
#reconnect_interval ⇒ Object
Returns the value of attribute reconnect_interval.
9
10
11
|
# File 'lib/volt/page/channel.rb', line 9
def reconnect_interval
@reconnect_interval
end
|
Returns the value of attribute status.
9
10
11
|
# File 'lib/volt/page/channel.rb', line 9
def status
@status
end
|
Instance Method Details
110
111
112
113
114
115
|
# File 'lib/volt/page/channel.rb', line 110
def close!
@status = :closed
%x{
this.socket.close();
}
end
|
#closed(error) ⇒ Object
61
62
63
64
65
66
67
68
69
70
|
# File 'lib/volt/page/channel.rb', line 61
def closed(error)
@status = :closed
@connected = false
@error = `error.reason`
trigger!('closed')
trigger!('changed')
reconnect!
end
|
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
# File 'lib/volt/page/channel.rb', line 30
def connect!
%x{
this.socket = new SockJS('/channel');
this.socket.onopen = function() {
self.$opened();
};
this.socket.onmessage = function(message) {
self['$message_received'](message.data);
};
this.socket.onclose = function(error) {
self.$closed(error);
};
}
end
|
22
23
24
|
# File 'lib/volt/page/channel.rb', line 22
def connected?
@connected
end
|
#message_received(message) ⇒ Object
90
91
92
93
|
# File 'lib/volt/page/channel.rb', line 90
def message_received(message)
message = JSON.parse(message)
trigger!('message', nil, *message)
end
|
48
49
50
51
52
53
54
55
56
57
58
59
|
# File 'lib/volt/page/channel.rb', line 48
def opened
@status = :open
@connected = true
@reconnect_interval = nil
@retry_count = 0
@queue.each do |message|
send_message(message)
end
trigger!('open')
trigger!('changed')
end
|
#reconnect! ⇒ Object
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
# File 'lib/volt/page/channel.rb', line 72
def reconnect!
@status = :reconnecting
@reconnect_interval ||= 0
@reconnect_interval += (2000 + rand(5000))
@retry_count += 1
trigger!('changed')
interval = @reconnect_interval
%x{
setTimeout(function() {
self['$connect!']();
}, interval);
}
end
|
#retry_count ⇒ Object
26
27
28
|
# File 'lib/volt/page/channel.rb', line 26
def retry_count
@retry_count
end
|
#send_message(message) ⇒ Object
98
99
100
101
102
103
104
105
106
107
108
|
# File 'lib/volt/page/channel.rb', line 98
def send_message(message)
if @status != :open
@queue << message
else
message = JSON.dump([message])
%x{
this.socket.send(message);
}
end
end
|