diff --git a/.gitignore b/.gitignore
index 27106d2..e7602b7 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,8 @@
 .project
+
+/.packages
+/.pub
 packages
+/pubspec.lock
 
+/coverage
\ No newline at end of file
diff --git a/README.md b/README.md
index ccee3ad..cb53970 100644
--- a/README.md
+++ b/README.md
@@ -11,4 +11,21 @@ presents them through WebSocket-like abstractions.
 
 SockJS is intended to work for all modern browsers and in environments
 which don't support WebSocket protocol, for example behind restrictive
-corporate proxies.
\ No newline at end of file
+corporate proxies.
+
+## Development
+
+### Dependencies
+```
+$ pub get && npm install
+```
+
+### Tests
+```
+$ pub run dart_dev test --integration
+```
+
+### Coverage
+```
+$ pub run dart_dev coverage --integration
+```
\ No newline at end of file
diff --git a/lib/sockjs_client.dart b/lib/sockjs_client.dart
index 6298b20..ddd81b7 100644
--- a/lib/sockjs_client.dart
+++ b/lib/sockjs_client.dart
@@ -1,6 +1,6 @@
 library sockjs_client;
 
-import "dart:html";
+import "dart:html" as html;
 import "dart:convert";
 import "dart:async";
 import "dart:js";
@@ -25,7 +25,7 @@ const OPEN = 1;
 const CLOSING = 2;
 const CLOSED = 3;
 
-typedef TransformFactory(Client client, String transUrl, [String baseUrl]);
+typedef TransformFactory(Client client, String transUrl, {String baseUrl, bool noCredentials});
 
 class Protocol {
   TransformFactory create;
diff --git a/lib/src/ajax.dart b/lib/src/ajax.dart
index 4ca9843..5917091 100644
--- a/lib/src/ajax.dart
+++ b/lib/src/ajax.dart
@@ -6,21 +6,21 @@ class StatusEvent extends event.Event {
   StatusEvent(String type, [this.status = 0, this.text = ""]) : super(type);
 }
 
-typedef AbstractXHRObject AjaxObjectFactory(String method, String baseUrl, [payload]);
+typedef AbstractXHRObject AjaxObjectFactory(String method, String baseUrl, {bool noCredentials, payload});
 
 class AbstractXHRObject extends Object with event.Emitter {
 
-  HttpRequest xhr;
+  html.HttpRequest xhr;
   StreamSubscription changeSubscription;
 
   Stream get onChunk => this["chunk"];
   Stream get onFinish => this["finish"];
   Stream get onTimeout => this["timeout"];
 
-  _start(method, url, payload, {noCredentials: false, headers}) {
+  _start(method, url, payload, {bool noCredentials: false, headers}) {
 
     try {
-        xhr = new HttpRequest();
+        xhr = new html.HttpRequest();
     } catch(x) {};
 
     if ( xhr == null ) {
@@ -61,7 +61,7 @@ class AbstractXHRObject extends Object with event.Emitter {
     xhr.send(payload);
   }
 
-  _readyStateHandler(Event evt) {
+  _readyStateHandler(html.Event evt) {
     switch (xhr.readyState) {
       case 3:
         var text, status;
@@ -106,22 +106,22 @@ class AbstractXHRObject extends Object with event.Emitter {
 }
 
 class XHRCorsObject extends AbstractXHRObject {
-   XHRCorsObject(method, url, payload, {noCredentials, headers} )  {
-    Timer.run(() =>_start(method, url, payload, noCredentials: false));
+   XHRCorsObject(method, url, {headers, noCredentials, payload})  {
+    Timer.run(() =>_start(method, url, payload, noCredentials: noCredentials != null ? noCredentials : false));
    }
 }
 
 
 
 class XHRLocalObject extends AbstractXHRObject {
-  XHRLocalObject (method, url, payload, {noCredentials, headers}) {
-    Timer.run(() =>_start(method, url, payload, noCredentials: true));
+  XHRLocalObject(method, url, {headers, noCredentials, payload}) {
+    Timer.run(() =>_start(method, url, payload, noCredentials: noCredentials != null ? noCredentials : true));
     }
 }
 
-XHRLocalObjectFactory(method, baseUrl, [payload]) => new XHRLocalObject(method, baseUrl, payload);
+XHRLocalObjectFactory(method, baseUrl, {bool noCredentials, payload}) => new XHRLocalObject(method, baseUrl, noCredentials: noCredentials, payload: payload);
 
-XHRCorsObjectFactory(method, baseUrl, [payload]) => new XHRCorsObject(method, baseUrl, payload);
+XHRCorsObjectFactory(method, baseUrl, {bool noCredentials, payload}) => new XHRCorsObject(method, baseUrl, noCredentials: noCredentials, payload: payload);
 
 // 1. Is natively via XHR
 // 2. Is natively via XDR
diff --git a/lib/src/client.dart b/lib/src/client.dart
index 43b0c9a..2d34d88 100644
--- a/lib/src/client.dart
+++ b/lib/src/client.dart
@@ -33,6 +33,8 @@ class Client extends Object with event.Emitter {
   num roundTrips;
   num timeout;
 
+  bool noCredentials;
+
   var _ir;
 
   var _transport = null;
@@ -42,6 +44,7 @@ class Client extends Object with event.Emitter {
                       this.debug: false,
                       this.protocolsWhitelist,
                       this.info,
+                      this.noCredentials: false,
                       this.rtt: 0,
                       this.server,
                       this.roundTrips,
@@ -70,6 +73,22 @@ class Client extends Object with event.Emitter {
   Stream get onClose => this["close"];
   Stream get onHeartbeat => this["heartbeat"];
 
+  void close([int code, String reason]) {
+    if (_transport != null) {
+      if (_transport is WebSocketTransport) {
+        _transport.doClose(code, reason);
+      } else if (_transport is XhrStreamingTransport) {
+        if (code == null) {
+          code = 0;
+        }
+        if (reason == null) {
+          reason = '';
+        }
+        _didClose(code, reason);
+      }
+    }
+  }
+
   send(data) {
     if (readyState == CONNECTING) {
         throw 'INVALID_STATE_ERR';
@@ -199,11 +218,11 @@ class Client extends Object with event.Emitter {
       // the `head`?
       if (PROTOCOLS.containsKey(protocol) &&
           PROTOCOLS[protocol].needBody &&
-          ( (document.body == null) || (document.readyState != null && document.readyState != 'complete'))
+          ( (html.document.body == null) || (html.document.readyState != null && html.document.readyState != 'complete'))
           ) {
           _protocols.insert(0, protocol);
           this.protocol = 'waiting-for-load';
-          document.onLoad.listen( (_) => _tryNextProtocol());
+          html.document.onLoad.listen( (_) => _tryNextProtocol());
           return true;
       }
 
@@ -234,7 +253,7 @@ class Client extends Object with event.Emitter {
           var connid = utils.random_string(8);
           var trans_url = "$_baseUrl/$server/$connid";
           _debug('Opening transport: $protocol url:$trans_url RTO:$rto roundTrips:$roundTrips timeout:$to');
-          _transport = PROTOCOLS[protocol].create(this, trans_url, _baseUrl);
+          _transport = PROTOCOLS[protocol].create(this, trans_url, baseUrl: _baseUrl, noCredentials: noCredentials);
           return true;
       }
     }
diff --git a/lib/src/info.dart b/lib/src/info.dart
index 389d711..5c1db15 100644
--- a/lib/src/info.dart
+++ b/lib/src/info.dart
@@ -12,7 +12,7 @@ class Info {
     origins = json["origins"];
     cookieNeeded = json["cookie_needed"];
     entropy = json["entropy"];
-    nullOrigin = (document.domain == null);
+    nullOrigin = (html.document.domain == null);
   }
 }
 
@@ -84,8 +84,8 @@ class AjaxInfoReceiver extends InfoReceiver {
 class InfoReceiverIframe extends InfoReceiver {
 
   InfoReceiverIframe(base_url) : super._() {
-    if(document.body == null) {
-      document.onLoad.listen((_) => go());
+    if(html.document.body == null) {
+      html.document.onLoad.listen((_) => go());
     } else {
         go();
     }
diff --git a/lib/src/transport/polling.dart b/lib/src/transport/polling.dart
index 852cc9a..6749d41 100644
--- a/lib/src/transport/polling.dart
+++ b/lib/src/transport/polling.dart
@@ -8,13 +8,14 @@ class Polling {
   AjaxObjectFactory xhrFactory;
   XhrReceiver poll;
   bool pollIsClosing = false;
+  bool noCredentials;
 
-  Polling(this.ri, this.receiverFactory, this.recvUrl, this.xhrFactory) {
+  Polling(this.ri, this.receiverFactory, this.recvUrl, this.xhrFactory, {bool this.noCredentials}) {
     _scheduleRecv();
   }
 
   _scheduleRecv() {
-    poll =  receiverFactory(recvUrl, xhrFactory);
+    poll =  receiverFactory(recvUrl, xhrFactory, noCredentials: noCredentials);
     var msg_counter = 0;
     var msgHandler = (e) {
       msg_counter += 1;
diff --git a/lib/src/transport/receiver-xhr.dart b/lib/src/transport/receiver-xhr.dart
index 812b050..d78e8a1 100644
--- a/lib/src/transport/receiver-xhr.dart
+++ b/lib/src/transport/receiver-xhr.dart
@@ -4,10 +4,10 @@ part of sockjs_client;
 
    AbstractXHRObject xo = null;
 
-   XhrReceiver(url, AjaxObjectFactory xhrFactory) {
+   XhrReceiver(url, AjaxObjectFactory xhrFactory, {bool noCredentials}) {
     var buf_pos = 0;
 
-    xo = xhrFactory('POST', url);
+    xo = xhrFactory('POST', url, noCredentials: noCredentials);
     xo.onChunk.listen((e){
         if (e.status != 200) return;
         while (true) {
@@ -36,4 +36,4 @@ part of sockjs_client;
   }
 }
 
-XhrReceiverFactory(String recvUrl, AjaxObjectFactory xhrFactory) => new XhrReceiver(recvUrl, xhrFactory);
+XhrReceiverFactory(String recvUrl, AjaxObjectFactory xhrFactory, {bool noCredentials}) => new XhrReceiver(recvUrl, xhrFactory, noCredentials: noCredentials);
diff --git a/lib/src/transport/sender.dart b/lib/src/transport/sender.dart
index 2b4b771..69870b8 100644
--- a/lib/src/transport/sender.dart
+++ b/lib/src/transport/sender.dart
@@ -66,18 +66,18 @@ class BufferedSender {
 // postMessage communication */
 class JsonPGenericSender {
 
-  FormElement _sendForm = null;
-  TextAreaElement _sendArea = null;
+  html.FormElement _sendForm = null;
+  html.TextAreaElement _sendArea = null;
 
   var completed;
 
   JsonPGenericSender(url, payload, callback) {
-    FormElement form;
-    TextAreaElement area;
+    html.FormElement form;
+    html.TextAreaElement area;
 
     if (_sendForm == null) {
-      form = _sendForm = new Element.tag('form');
-      area = _sendArea = new Element.tag('textarea');
+      form = _sendForm = new html.Element.tag('form');
+      area = _sendArea = new html.Element.tag('textarea');
       area.name = 'd';
       form.style.display = 'none';
       form.style.position = 'absolute';
@@ -85,7 +85,7 @@ class JsonPGenericSender {
       form.enctype = 'application/x-www-form-urlencoded';
       form.acceptCharset = "UTF-8";
       form.children.add(area);
-      document.body.children.add(form);
+      html.document.body.children.add(form);
     }
     form = _sendForm;
     area = _sendArea;
@@ -93,12 +93,12 @@ class JsonPGenericSender {
     form.target = id;
     form.action = '$url/jsonp_send?i=$id';
 
-    IFrameElement iframe;
+    html.IFrameElement iframe;
     try {
         // ie6 dynamic iframes with target="" support (thanks Chris Lambacher)
-        iframe = new Element.html('<iframe name="$id">');
+        iframe = new html.Element.html('<iframe name="$id">');
     } catch(x) {
-        iframe = new Element.tag('iframe');
+        iframe = new html.Element.tag('iframe');
         iframe.name = id;
     }
     iframe.id = id;
@@ -142,9 +142,9 @@ class JsonPGenericSender {
   }
 }
 
-createAjaxSender(AjaxObjectFactory xhrFactory)
+createAjaxSender(AjaxObjectFactory xhrFactory, {bool noCredentials})
     => (url, payload, callback([status, reason])) {
-        AbstractXHRObject xo = xhrFactory('POST', '$url/xhr_send', payload);
+        AbstractXHRObject xo = xhrFactory('POST', '$url/xhr_send', payload: payload, noCredentials: noCredentials);
         xo.onFinish.listen((e) {
             callback(e.status);
         });
diff --git a/lib/src/transport/websocket.dart b/lib/src/transport/websocket.dart
index 7bb3366..0e35e68 100644
--- a/lib/src/transport/websocket.dart
+++ b/lib/src/transport/websocket.dart
@@ -4,11 +4,11 @@ class WebSocketTransport {
   Client ri;
   String url;
 
-  WebSocket ws;
+  html.WebSocket ws;
   StreamSubscription messageSubscription;
   StreamSubscription closeSubscription;
 
-  static create(ri, transUrl, [baseUrl]) => new WebSocketTransport(ri, transUrl);
+  static create(ri, transUrl, {baseUrl, bool noCredentials}) => new WebSocketTransport(ri, transUrl);
 
   WebSocketTransport(this.ri, transUrl) {
     var url = '$transUrl/websocket';
@@ -20,7 +20,7 @@ class WebSocketTransport {
 
     this.url = url;
 
-    ws = new WebSocket(url);
+    ws = new html.WebSocket(url);
 
 
     messageSubscription = ws.onMessage.listen(_msgHandler);
@@ -37,7 +37,17 @@ class WebSocketTransport {
 
   _msgHandler(m) => ri._didMessage(m.data);
 
-  _closeHandler(m) => ri._didMessage(utils.closeFrame(1006, "WebSocket connection broken"));
+  _closeHandler(html.CloseEvent c) {
+    var code = c.code != null ? c.code : 1006;
+    var reason = c.reason != null ? c.reason : 'WebSocket connection broken';
+    ri._didMessage(utils.closeFrame(code, reason));
+  }
+
+  doClose([int code, String reason]) {
+    if (ws != null) {
+      ws.close(code, reason);
+    }
+  }
 
   doSend(data) => ws.send('[$data]');
 
diff --git a/lib/src/transport/xhr.dart b/lib/src/transport/xhr.dart
index 83eda66..23da8cc 100644
--- a/lib/src/transport/xhr.dart
+++ b/lib/src/transport/xhr.dart
@@ -6,11 +6,11 @@ class AjaxBasedTransport extends BufferedSender {
 
   Polling poll = null;
 
-  AjaxBasedTransport(Client ri, transUrl, urlSuffix, ReceiverFactory receiverFactory, AjaxObjectFactory xhrFactory) {
+  AjaxBasedTransport(Client ri, transUrl, urlSuffix, ReceiverFactory receiverFactory, AjaxObjectFactory xhrFactory, {bool noCredentials}) {
     this.ri = ri;
     this.transUrl = transUrl;
-    sendConstructor(createAjaxSender(xhrFactory));
-    this.poll = new Polling(ri, receiverFactory, "$transUrl$urlSuffix", xhrFactory);
+    sendConstructor(createAjaxSender(xhrFactory, noCredentials: noCredentials));
+    this.poll = new Polling(ri, receiverFactory, "$transUrl$urlSuffix", xhrFactory, noCredentials: noCredentials);
   }
 
   doCleanup() {
@@ -25,10 +25,10 @@ class AjaxBasedTransport extends BufferedSender {
 
 class XhrStreamingTransport extends AjaxBasedTransport {
 
-  XhrStreamingTransport(ri, transUrl) :
-    super(ri, transUrl, '/xhr_streaming', XhrReceiverFactory, XHRCorsObjectFactory);
+  XhrStreamingTransport(ri, transUrl, {bool noCredentials}) :
+    super(ri, transUrl, '/xhr_streaming', XhrReceiverFactory, XHRCorsObjectFactory, noCredentials: noCredentials);
 
-  static create(ri, transUrl, [baseUrl]) => new XhrStreamingTransport(ri, transUrl);
+  static create(ri, transUrl, {baseUrl, bool noCredentials}) => new XhrStreamingTransport(ri, transUrl, noCredentials: noCredentials);
 
   static bool get enabled {
     return true;
diff --git a/package.json b/package.json
new file mode 100644
index 0000000..2804fd7
--- /dev/null
+++ b/package.json
@@ -0,0 +1,17 @@
+{
+  "name": "sockjs-dart-client",
+  "version": "0.2.0",
+  "description": "A SockJS client in Dart",
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/Workiva/sockjs-dart-client.git"
+  },
+  "bugs": {
+    "url": "https://github.com/Workiva/sockjs-dart-client/issues"
+  },
+  "homepage": "https://github.com/Workiva/sockjs-dart-client",
+  "devDependencies": {
+    "http": "0.0.0",
+    "sockjs": "^0.3.15"
+  }
+}
diff --git a/pubspec.yaml b/pubspec.yaml
index 9821a79..732b0ec 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -8,5 +8,10 @@ authors:
 dependencies:
   browser: '>=0.9.0 <1.0.0'
   logging: '>=0.9.0 <1.0.0'
+dev_dependencies:
+  coverage: '>=0.7.2'
+  dart_dev: '>=1.0.2'
+  dart_style: '>=0.2.0'
+  test: '>=0.12.5'
 environment:
   sdk: '>=1.0.0 <2.0.0'
\ No newline at end of file
diff --git a/test/sockjs_client_integration_test.dart b/test/sockjs_client_integration_test.dart
new file mode 100644
index 0000000..5b51fce
--- /dev/null
+++ b/test/sockjs_client_integration_test.dart
@@ -0,0 +1,104 @@
+@TestOn('browser')
+library sockjs_client.test.sockjs_client_test;
+
+import 'dart:async';
+
+import 'package:sockjs_client/sockjs_client.dart';
+import 'package:test/test.dart';
+
+const String echoUri = 'http://localhost:8000/echo';
+const String corUri = 'http://localhost:8000/cor';
+const String fofUri = 'http://localhost:8600/404';
+
+void main() {
+  group('SockJS Client', () {
+    group('default', () {
+      Client createEchoClient() => new Client(echoUri, noCredentials: true);
+      Client createCorClient() => new Client(corUri, noCredentials: true);
+      Client create404Client() => new Client(fofUri, noCredentials: true);
+
+      integrationSuite(createEchoClient, createCorClient, create404Client);
+    });
+
+    group('web-socket', () {
+      Client createEchoClient() => new Client(echoUri, noCredentials: true, protocolsWhitelist: ['websocket']);
+      Client createCorClient() => new Client(corUri, noCredentials: true, protocolsWhitelist: ['websocket']);
+      Client create404Client() => new Client(fofUri, noCredentials: true, protocolsWhitelist: ['websocket']);
+
+      integrationSuite(createEchoClient, createCorClient, create404Client);
+    });
+
+    group('xhr-streaming', () {
+      Client createEchoClient() => new Client(echoUri, noCredentials: true, protocolsWhitelist: ['xhr-streaming']);
+      Client createCorClient() => new Client(corUri, noCredentials: true, protocolsWhitelist: ['xhr-streaming']);
+      Client create404Client() => new Client(fofUri, noCredentials: true, protocolsWhitelist: ['xhr-streaming']);
+
+      integrationSuite(createEchoClient, createCorClient, create404Client);
+    });
+  });
+}
+
+void integrationSuite(Client createEchoClient(), Client createCorClient(), Client create404Client()) {
+  test('connecting to a SockJS server', () async {
+    Client client = createEchoClient();
+    await client.onOpen.first;
+  });
+
+  test('sending and receiving messages', () async {
+    Client client = createEchoClient();
+    await client.onOpen.first;
+
+    Completer c = new Completer();
+    var echos = [];
+    client.onMessage.listen((MessageEvent message) {
+      echos.add(message.data);
+      if (echos.length == 2) {
+        c.complete();
+      }
+    });
+    client.send('message1');
+    client.send('message2');
+
+    await c.future;
+    client.close();
+
+    expect(echos, equals(['message1', 'message2']));
+  });
+
+  test('client closing the connection', () async {
+    Client client = createEchoClient();
+    await client.onOpen.first;
+    client.close();
+    await client.onClose.first;
+  });
+
+  test('client closing the connection with code and reason', () async {
+    Client client = createEchoClient();
+    await client.onOpen.first;
+    client.close(4001, 'Custom close.');
+    CloseEvent event = await client.onClose.first;
+    expect(event.code, equals(4001));
+    expect(event.reason, equals('Custom close.'));
+  });
+
+  test('server closing the connection', () async {
+    Client client = createCorClient();
+    await client.onOpen.first;
+    client.send('close');
+    await client.onClose.first;
+  });
+
+  test('server closing the connection with code and reason', () async {
+    Client client = createCorClient();
+    await client.onOpen.first;
+    client.send('close::4001::Custom close.');
+    CloseEvent event = await client.onClose.first;
+    expect(event.code, equals(4001));
+    expect(event.reason, equals('Custom close.'));
+  });
+
+  test('handle failed connection', () async {
+    Client client = create404Client();
+    await client.onClose.first;
+  });
+}
\ No newline at end of file
diff --git a/tool/dev.dart b/tool/dev.dart
new file mode 100644
index 0000000..1071521
--- /dev/null
+++ b/tool/dev.dart
@@ -0,0 +1,56 @@
+library tool.dev;
+
+import 'dart:async';
+import 'dart:io';
+
+import 'package:dart_dev/dart_dev.dart' show dev, config;
+import 'package:dart_dev/util.dart' show TaskProcess, reporter;
+
+main(List<String> args) async {
+  // https://github.com/Workiva/dart_dev
+
+  config.analyze.entryPoints = ['example/', 'lib/', 'tool/'];
+  config.format.directories = ['example/', 'lib/', 'tool/'];
+
+  config.coverage
+    ..before = [_startServer]
+    ..after = [_stopServer];
+  config.test
+    ..before = [_startServer]
+    ..after = [_stopServer]
+    ..unitTests = []
+    ..integrationTests = ['test/sockjs_client_integration_test.dart']
+    ..platforms = ['content-shell', 'dartium'];
+
+  await dev(args);
+}
+
+/// Server needed for integration tests and examples.
+TaskProcess _server;
+
+/// Output from the server (only used if caching the output to dump at the end).
+List<String> _serverOutput;
+
+/// Start the server needed for integration tests and cache the server output
+/// until the task requiring the server has finished. Then, the server output
+/// will be dumped all at once.
+Future _startServer() async {
+  _serverOutput = [];
+  _server = new TaskProcess('node', ['tool/server.js']);
+  _server.stdout.listen(_serverOutput.add);
+  _server.stderr.listen(_serverOutput.add);
+  // todo: wait for server to start
+}
+
+/// Stop the server needed for integration tests.
+Future _stopServer() async {
+  if (_serverOutput != null) {
+    reporter.logGroup('HTTP Server Logs',
+        output: '    ${_serverOutput.join('\n')}');
+  }
+  if (_server != null) {
+    try {
+      _server.kill();
+    } catch (e) {}
+  }
+}
diff --git a/tool/server.js b/tool/server.js
new file mode 100644
index 0000000..0da703a
--- /dev/null
+++ b/tool/server.js
@@ -0,0 +1,42 @@
+var http = require('http');
+var sockjs = require('sockjs');
+
+
+var echo = sockjs.createServer();
+echo.on('connection', function(conn) {
+    conn.on('data', function(message) {
+        console.log('[echo] "' + message + '"');
+        conn.write(message);
+    });
+    conn.on('close', function() {
+        console.log('[echo] closed.');
+    });
+});
+
+var closeOnRequest = sockjs.createServer();
+closeOnRequest.on('connection', function(conn) {
+    conn.on('data', function(message) {
+        if (message.substr(0, 'close'.length) === 'close') {
+            var parts = message.split('::');
+            var code;
+            var reason;
+            if (parts.length >= 2) {
+                code = parseInt(parts[1], 10);
+            }
+            if (parts.length >= 3) {
+                reason = parts[2];
+            }
+            console.log('[cor] close request received');
+            conn.close(code, reason);
+        }
+    });
+    conn.on('close', function() {
+        console.log('[cor] closed.');
+    });
+
+});
+
+var server = http.createServer();
+echo.installHandlers(server, {prefix: '/echo'});
+closeOnRequest.installHandlers(server, {prefix: '/cor'});
+server.listen(8000, 'localhost');
\ No newline at end of file