thisisjofrank

private async onPresenceChanged() {
    const members = await this.channel.presence.get();
    this.ensureLeaderElected(members);
    this.onSwarmPresenceChanged(members);
}

thisisjofrank

public async connect() {
    this.channel.presence.subscribe(this.onPresenceChanged.bind(this));
    await this.channel.presence.enter('connected');
    this.onConnection(this.channel);
}

thisisjofrank

constructor(channelName: string) {
    this.id = Math.floor(Math.random() * 1000000) + "";
    this.ably = new Ably.Realtime({ key: "api-key-here", clientId: this.id });
    this.channel = this.ably.channels.get(channelName);
}

thisisjofrank

public onElection: (channel: Types.RealtimeChannelPromise) => void = () => {};
public onConnection: (channel: Types.RealtimeChannelPromise) => void = () => {};
public onSwarmPresenceChanged: (members: Types.PresenceMessage[]) => void = () => {};

thisisjofrank

import { Types } from 'ably'; 
import Ably from 'ably/promises'; 
export default class Swarm { 
    public readonly id: string; 
    private readonly ably: Ably.Realtime; 
    private readonly channel: Types.RealtimeChannelPromise;

thisisjofrank

import React, { useState, useEffect } from 'react';
import Ably from "ably/promises";

const client = new Ably.Realtime("you-api-key-here");

const Component = (props) => {

    const channel = client.channels.get('some-channel');
    const [ messages, updateMessages ] = useState([]);

thisisjofrank

classCountComponent extends HTMLElement {
}

thisisjofrank

var net = require('net');

var path = require('path');
const express = require('express');
const bodyParser = require('body-parser');
const app = express();
const port = 3141;

const fetch = require("node-fetch");

thisisjofrank

thisisjofrank

import React from 'react'
import Ably from "ably/promises";

const client = new Ably.Realtime("your-ably-api-key");

export default class AblyMessageComponent extends React.Component {
    
    constructor() {
        super();
        this.state = { messages: [] };