diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2017-02-18 13:18:59 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2017-02-18 13:18:59 +0900 |
| commit | 4770e1fab89b35671f9fd1eb3080efca717e27ac (patch) | |
| tree | 1fa19779dadb27bf1804d4338409146adf62af74 /src/web/app/common/scripts/stream.ls | |
| parent | :v: (diff) | |
| download | sharkey-4770e1fab89b35671f9fd1eb3080efca717e27ac.tar.gz sharkey-4770e1fab89b35671f9fd1eb3080efca717e27ac.tar.bz2 sharkey-4770e1fab89b35671f9fd1eb3080efca717e27ac.zip | |
:v:
Diffstat (limited to 'src/web/app/common/scripts/stream.ls')
| -rw-r--r-- | src/web/app/common/scripts/stream.ls | 39 |
1 files changed, 0 insertions, 39 deletions
diff --git a/src/web/app/common/scripts/stream.ls b/src/web/app/common/scripts/stream.ls deleted file mode 100644 index c2c061603e..0000000000 --- a/src/web/app/common/scripts/stream.ls +++ /dev/null @@ -1,39 +0,0 @@ -# Stream -#================================ - -ReconnectingWebSocket = require \reconnecting-websocket -riot = require \riot - -module.exports = (me) ~> - state = \initializing - state-ev = riot.observable! - event = riot.observable! - - host = CONFIG.api.url.replace \http \ws - socket = new ReconnectingWebSocket "#{host}?i=#{me.token}" - - socket.onopen = ~> - state := \connected - state-ev.trigger \connected - - socket.onclose = ~> - state := \reconnecting - state-ev.trigger \closed - - socket.onmessage = (message) ~> - try - message = JSON.parse message.data - if message.type? - event.trigger message.type, message.body - catch - # ignore - - get-state = ~> state - - event.on \i_updated me.update - - { - state-ev - get-state - event - } |