PenServerPlainTextSender.java

package edu.stanford.hci.r3.pen.streaming.data;

import java.io.BufferedOutputStream;
import java.io.IOException;
import java.net.Socket;

import edu.stanford.hci.r3.pen.PenSample;
import edu.stanford.hci.r3.util.SystemUtils;

public class PenServerPlainTextSender implements PenServerSender {

        private Socket socket;

        private BufferedOutputStream bos;

        public PenServerPlainTextSender(Socket sock) throws IOException {
                socket = sock;
                bos = new BufferedOutputStream(sock.getOutputStream());
        }

        public void sendSample(PenSample as) throws IOException {
                bos.write((as.toCommaSeparatedString() + SystemUtils.LINE_SEPARATOR).getBytes());
                bos.flush();
        }

        public void destroy() {
                try {
                        if (bos != null) {
                                bos.close();
                                bos = null;
                        }
                        if (socket != null) {
                                socket.close();
                                socket = null;
                        }
                } catch (IOException ioe) {
                        System.out.println("Got exception when destroying PlainTextServerOutput: "
                                        + ioe.getLocalizedMessage());
                }
        }
}

---