def server_pusblish_event(current_topic, message)
      @server.mutex.synchronize do
        (@server.subscribers[current_topic].dup || []).pmap do |hash|
          hash[:reactor].websocket << message
        end
      end
    end
def server_pusblish_event(current_topic, message)
      @server.mutex.synchronize do
        (@server.subscribers[current_topic].dup || []).pmap do |hash|
          hash[:reactor].websocket << message
        end
      end
    end
the method will publish to all subsribers of a channel a message

 @param [String] current_topic
 @param [#to_s] message

 @return [void]

 @api public