Add fetch() streaming source, close #119, #300

build.sh

@@ -63,6 +63,7 @@ cat \
 	src/player.js \
 	src/buffer.js \
 	src/ajax.js \
+	src/fetch.js \
 	src/ajax-progressive.js \
 	src/websocket.js \
 	src/ts.js \

src/ajax-progressive.js

@@ -4,6 +4,7 @@ var AjaxProgressiveSource = function(url, options) {
 	this.url = url;
 	this.destination = null;
 	this.request = null;
+	this.streaming = false;
 
 	this.completed = false;
 	this.established = false;

src/ajax.js

@@ -4,6 +4,7 @@ var AjaxSource = function(url, options) {
 	this.url = url;
 	this.destination = null;
 	this.request = null;
+	this.streaming = false;
 
 	this.completed = false;
 	this.established = false;

src/fetch.js

@@ -0,0 +1,75 @@
+JSMpeg.Source.Fetch = (function(){ "use strict";
+
+var FetchSource = function(url, options) {
+	this.url = url;
+	this.destination = null;
+	this.request = null;
+	this.streaming = true;
+
+	this.completed = false;
+	this.established = false;
+	this.progress = 0;
+	this.aborted = false;
+
+	this.onEstablishedCallback = options.onSourceEstablished;
+	this.onCompletedCallback = options.onSourceCompleted;
+};
+
+FetchSource.prototype.connect = function(destination) {
+	this.destination = destination;
+};
+
+FetchSource.prototype.start = function() {
+	var params = {
+		method: 'GET',
+		headers: new Headers(),
+		cache: 'default'
+	};
+	
+	self.fetch(this.url, params).then(function(res) {
+		console.log(res.value);
+		if (res.ok && (res.status >= 200 && res.status <= 299)) {
+			this.progress = 1;
+			this.established = true;
+			return this.pump(res.body.getReader());
+		}
+		else {
+			//error
+		}
+	}.bind(this)).catch(function(err) {
+		throw(err);
+	});
+};
+
+FetchSource.prototype.pump = function(reader) {
+	return reader.read().then(function(result) {
+		if (result.done) {
+			this.completed = true;
+		}
+		else {
+			if (this.aborted) {
+				return reader.cancel();
+			}
+			
+			if (this.destination) {
+				this.destination.write(result.value.buffer);
+			}
+
+			return this.pump(reader);
+		}
+	}.bind(this)).catch(function(err) {
+		throw(err);
+	});
+};
+
+FetchSource.prototype.resume = function(secondsHeadroom) {
+	// Nothing to do here
+};
+
+FetchSource.prototype.abort = function() {
+	this.aborted = true;
+};
+
+return FetchSource;
+
+})();

src/websocket.js

@@ -3,7 +3,8 @@ JSMpeg.Source.WebSocket = (function(){ "use strict";
 var WSSource = function(url, options) {
 	this.url = url;
 	this.options = options;
-	this.socket = null;	
+	this.socket = null;
+	this.streaming = true;
 
 	this.callbacks = {connect: [], data: []};
 	this.destination = null;