using System;
using System.Threading;
using Christie_net.datagear.command;

namespace Christie_net.daemon {
public class OutboundTcpConnection {

    private Connection connection;

    public OutboundTcpConnection(Connection connection) {
        this.connection = connection;
    }

    public void Run() {
        while (true) {
            try {
                Command cmd = connection.sendQueue.Take();
                switch (cmd.type) {
                    case CommandType.CLOSE:
                    case CommandType.FINISH:
                        cmd.Execute();
                        return;
                    default:
                        break;
                }
                connection.Write(cmd);
            } catch (ThreadInterruptedException e) {
                Console.WriteLine(e.StackTrace);
            }
        }
    }
    
    
}
}