diff --git a/lib/eventsource.dart b/lib/eventsource.dart
index 6eabc3f..54bbef2 100644
--- a/lib/eventsource.dart
+++ b/lib/eventsource.dart
@@ -34,6 +34,7 @@ class EventSource extends Stream<Event> {
   // interface attributes
 
   final Uri url;
+  final String authToken;
 
   EventSourceReadyState get readyState => _readyState;
 
@@ -55,7 +56,7 @@ class EventSource extends Stream<Event> {
 
   /// Create a new EventSource by connecting to the specified url.
   static Future<EventSource> connect(url,
-      {http.Client client, String lastEventId}) async {
+      {http.Client client, String lastEventId, String authToken}) async {
     // parameter initialization
     url = url is Uri ? url : Uri.parse(url);
     client = client ?? new http.Client();
@@ -82,6 +83,7 @@ class EventSource extends Stream<Event> {
     var request = new http.Request("GET", url);
     request.headers["Cache-Control"] = "no-cache";
     request.headers["Accept"] = "text/event-stream";
+    request.headers["Authorization"] = "Bearer $authToken";
     if (_lastEventId.isNotEmpty) {
       request.headers["Last-Event-ID"] = _lastEventId;
     }