module dreactor.util.Emitter;




import tango.core.Thread;

import dreactor.core.Task;
import dreactor.protocol.IProvider;

alias Message delegate() EmitterDg;

class Emitter
{
public
    this(Task t, EmitterDg cb)
    {
        task = t;
        callback = cb;
        thread = new Thread(&run);
        thread.start();
    }

    void stop()
    {
        running = false;
    }
    
    void stopNow()
    {
        thread.isDaemon(true);
        running = false;
    }
private

    void run()
    {
        while(running)
        {
            Message msg = callback();
            task.appendIVMessage(msg);
        }
    }
    Task task;
    Thread thread;
    bool running;
    EmitterDg callback;
}