1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768 |
- (function() {
- var e = {}.hasOwnProperty,
- t = function(t, r) {
- function o() {
- this.constructor = t
- }
- for(var n in r) e.call(r, n) && (t[n] = r[n]);
- return o.prototype = r.prototype, t.prototype = new o, t.__super__ = r.prototype, t
- };
- AV.WebSocketSource = function(e) {
- function r(e, t) {
- return this.serverUrl = e, this.fileName = t, "undefined" == typeof WebSocket || null === WebSocket ? this.emit("error", "This browser does not have WebSocket support.") : (this.socket = new WebSocket(this.serverUrl), null == this.socket.binaryType ? (this.socket.close(), this.emit("error", "This browser does not have binary WebSocket support.")) : (this.bytesLoaded = 0, this._setupSocket(), void 0))
- }
- return t(r, e), r.prototype.start = function() {
- // return this._send(JSON.stringify({
- // resume: !0
- // }))
- }, r.prototype.pause = function() {
- return
- }, r.prototype.reset = function() {
- return this._send(JSON.stringify({
- reset: !0
- }))
- }, r.prototype._send = function(e) {
- return this.open ? this.socket.send(e) : this._bufferMessage = e
- }, r.prototype._setupSocket = function() {
- var e = this;
- return this.socket.binaryType = "arraybuffer", this.socket.onopen = function() {
- return e.open = !0, e.fileName && e.socket.send(JSON.stringify({
- fileName: e.fileName
- })), e._bufferMessage ? (e.socket.send(e._bufferMessage), e._bufferMessage = null) : void 0
- }, this.socket.onmessage = function(t) {
- var r, o;
- r = new AV.Buffer(new Uint8Array(o))
- var se = t.data
-
- if(new Uint8Array(se)[0] == 0){
-
- // var messageData = new Uint8Array(se)
- // player.decode(messageData);
- // console.log('黄飞5')
- return
- }else{
- // console.log('黄飞6')
- // console.log('黄飞2',new Uint8Array(se)[0])
- return o = t.data, "string" != typeof o ? (r = new AV.Buffer(new Uint8Array(o)), e.bytesLoaded += r.length, e.length && e.emit("progress", 100 * (e.bytesLoaded / e.length)), e.emit("data", r)) : (o = JSON.parse(o), null != o.fileSize ? e.length = o.fileSize : null != o.error ? e.emit("error", o.error) : o.end ? e.socket.close() : void 0)
- }
-
-
- }, this.socket.onclose = function(t) {
- console.log('黄飞5')
- return e.open = !1, t.wasClean ? e.emit("end") : e.emit("error", "WebSocket closed uncleanly with code " + t.code + ".")
- }, this.socket.onerror = function(t) {
- console.log('黄飞6')
- return e.emit("error", t)
- }
- }, r
- }(AV.EventEmitter), AV.Asset.fromWebSocket = function(e, t) {
- var r;
- console.log('黄飞1')
- return r = new AV.WebSocketSource(e, t), new AV.Asset(r)
-
- }, AV.Player.fromWebSocket = function(e, t) {
- var r;
- console.log('黄飞2')
- return r = AV.Asset.fromWebSocket(e, t), new AV.Player(r)
- }
- }).call(this);
|