# File lib/nanite/streaming.rb, line 110 def subscribe_to_files(domain='global', write=false, &blk) Nanite::Log.info "subscribing to file broadcasts for #{domain}" @files ||= {} amq.queue("files#{domain}").bind(amq.topic('file broadcast'), :key => "nanite.filepeer.#{domain}").subscribe do |packet| case msg = serializer.load(packet) when FileStart @files[msg.token] = FileState.new(msg.token, msg.dest, domain, write, blk) when FileChunk, FileEnd if file = @files[msg.token] file.handle_packet(msg) end end end end