       lang_tag = TAPi18n.getLanguage()
 
       subscription =
-        Meteor.subscribe.apply @, removeTrailingUndefs [].concat(name, params, lang_tag, callbacks)
+        connection.subscribe.apply connection, removeTrailingUndefs [].concat(name, params, lang_tag, callbacks)
 
-      # if the subscription is already ready: 
+      # if the subscription is already ready:
       local_session.set("ready", subscription.ready())
 
   # If TAPi18n is called in a computation, to maintain Meteor.subscribe


  return obj

TAPi18n.subscribe = (name) ->
  local_session = new ReactiveDict
  local_session.set("ready", false)

  # parse arguments
  params = Array.prototype.slice.call(arguments, 1)
  callbacks = {}
  if params.length
    lastParam = params[params.length - 1]

  if currentComputation?
    # If TAPi18n.subscribe was called in a computation, call subscribe in a
    # non-reactive context, but make sure that if the computation is getting
    # invalidated also the subscription computation
    # (invalidations are allowed up->bottom but not bottom->up)
    Deps.onInvalidate ->
      subscription_computation.invalidate()
