initialize position (#11)

* initialize position

* maket test more versatile

Author: nick-zh

metadata_collection.c

@@ -186,7 +186,7 @@ ZEND_METHOD(Kafka_Metadata_Collection, next)
         return;
     }
 
-    intern->position ++;
+    intern->position++;
 }
 /* }}} */
 
@@ -243,4 +243,5 @@ void kafka_metadata_collection_obj_init(zval *return_value, Z_KAFKA_OBJ *zmetada
     intern->item_cnt = item_cnt;
     intern->item_size = item_size;
     intern->ctor = ctor;
+    intern->position = 0;
 }

tests/metadata.phpt

@@ -39,9 +39,16 @@ $producer->flush(10000);
 printf("%d messages delivered\n", $delivered);
 $metadata = $producer->getMetadata(false, 2*1000, $topic);
 echo $metadata->getOrigBrokerName() . PHP_EOL;
-echo $metadata->getTopics()->current()->getTopic() . PHP_EOL;
-echo $metadata->getTopics()->current()->getPartitions()->count() . PHP_EOL;
-echo $metadata->getTopics()->current()->getPartitions()->current()->getLeader() . PHP_EOL;
+
+$topics = $metadata->getTopics();
+
+while ($topics->valid()) {
+    echo $topics->current()->getTopic() . PHP_EOL;
+    echo $topics->current()->getPartitions()->count() . PHP_EOL;
+    echo $topics->current()->getPartitions()->current()->getLeader() . PHP_EOL;
+    $topics->next();
+}
+
 echo $metadata->getBrokers()->current()->getHost() . PHP_EOL;
 echo $metadata->getBrokers()->current()->getPort() . PHP_EOL;
 --EXPECT--