1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
# -*- coding: utf-8 -*-
require File.expand_path File.join(File.dirname(__FILE__), 'parma_streamer')
require File.expand_path File.join(File.dirname(__FILE__), 'filter')
Plugin.create :streaming do
streamers = {} # service_id => ParmaStreamer
Delayer.new {
Service.instances.each{ |service|
if UserConfig[:realtime_rewind]
streamers[service.name] ||= Plugin::Streaming::ParmaStreamer.new(service) end } }
rewind_switch_change_hook = UserConfig.connect(:realtime_rewind){ |key, new_val, before_val, id|
if new_val
streamers.values.each(&:kill)
streamers = {}
Service.instances.each{ |service|
streamers[service.name] ||= Plugin::Streaming::ParmaStreamer.new(service) }
else
Plugin.call(:gui_window_rewindstatus, Plugin::GUI::Window.instance(:default), _('UserStream: 接続を切りました'), 10)
streamers.values.each(&:kill)
streamers = {}
end
}
on_service_registered do |service|
if UserConfig[:realtime_rewind]
streamers[service.name] ||= Plugin::Streaming::ParmaStreamer.new(service) end end
on_service_destroyed do |service|
streamers[service.name] and streamers[service.name].kill end
onunload do
UserConfig.disconnect(rewind_switch_change_hook)
streamers.values.each(&:kill)
streamers = {} end
end
|
