Contents

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const ActionCable = require("actioncable");
class ActionCableAdapter {
    constructor() {
        this.connected = true;
        this.subscribe(Math.random().toString(), () => { });
    }
    subscribe(key, received) {
        const disconnected = () => {
            if (!this.connected)
                return;
            this.connected = false;
            this.ondisconnect();
        };
        const connected = () => {
            if (this.connected)
                return;
            this.connected = true;
            this.onreconnect();
        };
        if (!this._cable)
            this._cable = ActionCable.createConsumer();
        return this._cable.subscriptions.create({ channel: 'SyncChannel', key }, { received, disconnected, connected });
    }
    ondisconnect() { }
    onreconnect() { }
}
exports.default = ActionCableAdapter;

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ar_sync-1.0.1	core/ActioncableAdapter.js
ar_sync-1.0.0	core/ActioncableAdapter.js