module Restforce::Concerns::Streaming

def subscribe(channels, &block)

Returns a Faye::Subscription

block - A block to run when a new message is received.
channels - The name of the PushTopic channel(s) to subscribe to.

Public: Subscribe to a PushTopic
def subscribe(channels, &block)
  faye.subscribe Array(channels).map { |channel| "/topic/#{channel}" }, &block
end