diff --git a/src/video/index.js b/src/video/index.js
index 4983255de..e7b2bbb87 100644
--- a/src/video/index.js
+++ b/src/video/index.js
@@ -1,9 +1,11 @@
-const HTMLVideo = require('./HTMLVideo');
-const MPVVideo = require('./MPVVideo');
-const YouTubeVideo = require('./YouTubeVideo');
+var HTMLVideo = require('./HTMLVideo');
+var MPVVideo = require('./MPVVideo');
+var YouTubeVideo = require('./YouTubeVideo');
+var withStreamingServer = require('./withStreamingServer');
 
 module.exports = {
     HTMLVideo,
     MPVVideo,
-    YouTubeVideo
+    YouTubeVideo,
+    withStreamingServer
 };
diff --git a/src/video/withStreamingServer.js b/src/video/withStreamingServer.js
new file mode 100644
index 000000000..1b67f08f8
--- /dev/null
+++ b/src/video/withStreamingServer.js
@@ -0,0 +1,133 @@
+var UrlUtils = require('url');
+var EventEmitter = require('events');
+
+function withStreamingServer(Video) {
+    function StreamingServerVideo(options) {
+        var video = new Video(options);
+        var events = new EventEmitter();
+        var destroyed = false;
+        var stream = null;
+
+        events.on('error', function() { });
+
+        function onError(error) {
+            if (!error) {
+                return;
+            }
+
+            Object.freeze(error);
+            events.emit('error', error);
+            if (error.critical) {
+                video.dispatch({ commandName: 'stop' });
+            }
+        }
+
+        function on(eventName, listener) {
+            if (!destroyed) {
+                events.on(eventName, listener);
+            }
+
+            video.on(eventName, listener);
+        }
+        function dispatch(args) {
+            if (args && args.commandName === 'load') {
+                stream = null;
+                if (args.commandArgs && args.commandArgs.stream && typeof args.commandArgs.stream.infoHash === 'string' && typeof args.commandArgs.streamingServerUrl === 'string') {
+                    stream = args.commandArgs.stream;
+                    video.dispatch({ commandName: 'stop' });
+                    if (stream.fileIdx !== null && !isNaN(stream.fileIdx)) {
+                        video.dispatch({
+                            commandName: 'load',
+                            commandArgs: {
+                                autoplay: args.commandArgs.autoplay,
+                                time: args.commandArgs.time,
+                                stream: {
+                                    url: UrlUtils.resolve(args.commandArgs.streamingServerUrl, stream.infoHash + '/' + String(stream.fileIdx))
+                                }
+                            }
+                        });
+                    } else {
+                        fetch(UrlUtils.resolve(args.commandArgs.streamingServerUrl, stream.infoHash + '/create'), {
+                            method: 'POST',
+                            headers: {
+                                'content-type': 'application/json'
+                            },
+                            body: JSON.stringify({
+                                torrent: {
+                                    infoHash: stream.infoHash
+                                }
+                            })
+                        }).then(function(resp) {
+                            return resp.json();
+                        }).then(function(resp) {
+                            if (stream !== args.commandArgs.stream) {
+                                return;
+                            }
+
+                            if (!Array.isArray(resp.files) || resp.files.length === 0) {
+                                onError({
+                                    message: 'Unable to get files from torrent',
+                                    critical: true
+                                });
+                                return;
+                            }
+
+                            var fileIdx = resp.files.reduce((fileIdx, _, index, files) => {
+                                if (files[index].length > files[fileIdx].length) {
+                                    return index;
+                                }
+
+                                return fileIdx;
+                            }, 0);
+                            video.dispatch({
+                                commandName: 'load',
+                                commandArgs: {
+                                    autoplay: args.commandArgs.autoplay,
+                                    time: args.commandArgs.time,
+                                    stream: {
+                                        url: UrlUtils.resolve(args.commandArgs.streamingServerUrl, stream.infoHash + '/' + fileIdx)
+                                    }
+                                }
+                            });
+                        }).catch(function(error) {
+                            if (stream !== args.commandArgs.stream) {
+                                return;
+                            }
+
+                            onError({
+                                message: 'Unable to get files from torrent',
+                                critical: true,
+                                error: error
+                            });
+                        });
+                    }
+                }
+            } else {
+                if (args && args.commandName === 'destroy') {
+                    destroyed = true;
+                    events.removeAllListeners();
+                    events.on('error', function() { });
+                }
+
+                video.dispatch(args);
+            }
+        }
+
+        this.on = on;
+        this.dispatch = dispatch;
+
+        Object.freeze(this);
+    }
+
+    StreamingServerVideo.manifest = Object.freeze({
+        name: Video.manifest.name + 'WithStreamingServer',
+        embedded: true,
+        props: Object.freeze(Video.manifest.props)
+    });
+
+    Object.freeze(StreamingServerVideo);
+
+    return StreamingServerVideo;
+}
+
+module.exports = withStreamingServer;