Connection.dart

#library('dartmud:connection');

#import('dart:io');

class Connection {
  Socket _sock;
  StringInputStream _strInput;
  
  Connection(this._sock) {
    _strInput = new StringInputStream(_sock.inputStream);
    
    _sock.onError = (Exception e) { 
      print("An error has occurred with Connection#$_sock:");
      print(e);
      _sock.close();
    };
  }
  
  set onLine(Function func) => _strInput.onLine = func;
  
  int write(String str) {
    List<int> strCodes = str.charCodes();
    _sock.writeList(strCodes, 0, strCodes.length);
  }
  
  int writeLine(String str) => write("$str\n");
  
  String readLine() => _strInput.readLine().trim();
  
  void close() {
    writeLine('Goodbye!');
    _sock.close();
  }
}