Contents

class StreamNotificationsJob < Hyrax::ApplicationJob
  def perform(users)
    Array.wrap(users).each do |user|
      mailbox = UserMailbox.new(user)
      Hyrax::NotificationsChannel.broadcast_to(user,
                                               notifications_count: mailbox.unread_count,
                                               notifications_label: mailbox.label)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
hyrax-2.0.0.beta2	app/jobs/stream_notifications_job.rb