## # (IPC) クライアント(ブラウザ, JavaScript)からのリクエストを受け、 # メッセージ(イベント)をServerSentEventsプロトコルで返す。 # def ipc_a_listen_ssev( sock, param ) tid = param["LAST_EVENT_ID"] == 0 ? @msg.tid : param["LAST_EVENT_ID"] @msg.cycle( tid + 1 ) { |m| sock.puts "id: #{m[:TID].to_i}" sock.puts "data: #{m.to_json}" sock.puts "" } end