vanilla.consul fd leak

vanilla.consul.fd_leak

import vanilla, vanilla.consul
import consul

c = consul.Consul()
_, d = c.health.service('mogtracker', passing=1)
for row in d:
	print '%s:%d' % (row['Node']['Address'], row['Service']['Port'])

h = vanilla.Hub()

def Changes(h, service):
	sender, recver = h.pipe()

	@h.spawn
	def _():
		c = h.consul()
		index = None
		while True:
			index, nodes = c.health.service(service, index=index).recv()
			sender.send(nodes)

	return recver

for changes in Changes(h, 'hwy-store'):
	print changes