keunwoochoi · August 4, 2016 05:06
diff --git a/pescador_example.py b/pescador_example.py
 #!/usr/bin/env python

 import numpy as np
 import pescador

 def data_sampler(filename, n_samples):

    # Load all the data from the file, somehow
    data = load_data(filename)

    for n in range(n_samples):

        x, y = sample(data)
        yield dict(x=x, y=y)



 stream = pescador.Streamer(data_sampler, n_samples=128)

 streamer = pescador.zmq_stream(stream)

 for sample in steamer:
    process(sample)
	#!/usr/bin/env python

	import numpy as np
	import pescador

	def data_sampler(filename, n_samples):

	# Load all the data from the file, somehow
	data = load_data(filename)

	for n in range(n_samples):

	x, y = sample(data)
	yield dict(x=x, y=y)



	stream = pescador.Streamer(data_sampler, n_samples=128)

	streamer = pescador.zmq_stream(stream)

	for sample in steamer:
	process(sample)