REST APIのpolling実装を変更したことによる問題。

shareイベントを使う¶

現実装ではmentionイベントの中からshareに該当する物を探しているが、既にshareイベントがあるのでそれを使ったほうが良い。

ストリームイベントを用意する¶

ストリームにしておけばuniqとか使えるのでこの手の制御を楽にできる。

mention、favorite、unfavorite、share、followers_created、followers_destroyを受け取って、対応するストリームイベントを新設する。
既存のイベントは不要なのにServiceオブジェクト（現在はWorldに置き換わっている）を要求したりイベント名が変だったりする。

generate(:mention_stream) do |mention|
  on_mention do |_, messages|
    mention.bulk_add(messages)
  end
end

mention以外は、srcとdestの2つの引数が必要なので、単純にはストリームにできない。こういった用途のための（toとfromがあるような）Modelを定義する必要がありそう。