       _dumpTimer = Clock.createTimer()
     }
     
-
     if reading < 0 {
       fatalError()
     }

      defer {
        self.reading -= 1
      }
//      let timer = Clock.createTimer()
      guard let json = JSON(data: text.dataUsingEncoding(NSUTF8StringEncoding)!).dictionary else {
        print("Got message could not decode as JSON: ", text)
        return

  }
  
  func ageOfData(name : String) -> Double {
    return CACurrentMediaTime() - (_latestData[name]?.time ?? -Double.infinity)
  }
  
  func subscribe(name : String) {
