falsecz
10/1/2014 - 12:20 PM

zkwatchtest.coffee

zkwatch =  require './'

blockMe = (ms) ->
	console.log "Block start"
	d = new Date()
	while new Date - d < ms
		a = 1
	console.log "Block end"

zk = new zkwatch
	hosts: '127.0.0.1:2181'
	root: '/zktest'
	reconnectTimeout: 5000


zk.once 'connected', (err) ->
	console.log 'Connected'
	zk.watch '/root', (err, value, zstat) ->


setTimeout () ->
	blockMe 2000
, 2000


setTimeout () ->
	blockMe 2000
, 10000