```ruby
class QuarkChannel < ApplicationCable::Channel
  def subscribed
    stream_from 'quark:global'
    stream_from "quark:#{self}"
  end

  def create(data)
    return unless current_user

    quark = Quark.new(count: data['count'], user: current_user)
    if quark.save
      QuarkChannel.broadcast_to(:global, quark: quark, action: :created, status: :ok)
    else
      QuarkChannel.broadcast_to(self, action: :created, status: :error, messages: quark.errors.full_messages)
    end
  end

  def total_count
    QuarkChannel.broadcast_to(self, action: :total_count, status: :ok, count: Quark.total_count)
  end
end
```

Create error/success handlers for QuarkChannel
user
```ruby
class QuarkChannel < ApplicationCable::Channel
  def subscribed
    stream_from 'quark:global'
    stream_from "quark:#{self}"
  end

  def create(data)
    return unless current_user

    quark = Quark.new(count: data['count'], user: current_user)
    if quark.save
      success :global, :created, quark: quark, total_count: Quark.total_count
    else
      error self, :created, messages: quark.errors.full_messages
    end
  end

  def total_count
    success :total_count, total_count: Quark.total_count
  end

  private

  def success(channel, action, values)
    QuarkChannel.broadcast_to(channel, values.merge(action: action, status: :ok))
  end

  def error(channel, action, messages)
    QuarkChannel.broadcast_to(channel, action: action, status: :error, messages: messages)
  end
end
```
assistant