fixed listener

client/listener.go

@@ -22,7 +22,10 @@ func listen(c *FhoClient, object string, lastUpdatedTime time.Time, fn func(*[]m
 			log.Println("Error:", err.Error())
 			break
 		}
-		return fn(data)
+		err = fn(data)
+		if err != nil {
+			return err
+		}
 	}
 	return nil
 }

example/main.go

@@ -17,9 +17,9 @@ func main() {
 	if err != nil {
 		panic(err)
 	}
-	// go listenProducts(client)
+	go listenProducts(client)
 	// go listenPrices(client)
-	go query(client)
+	// go query(client)
 	// update(client)
 	// updateFromFHO(client)