FZambia

package smartbatching

import (
	"errors"
	"sync"
)

// T is a type Batcher works with.
type T interface{}

FZambia

//
//  ViewController.m
//  CentrifugoObjectiveC
//
//  Created by Alexander Emelin on 05/04/2017.
//  Copyright © 2017 Alexander Emelin. All rights reserved.
//
#import "Centrifuge/Centrifuge.objc.h"
#import "ViewController.h"

FZambia

package main

// Subscribe many clients, publish into channel, wait for all messages received.
// Supposed to run for channel which only have `publish` option enabled.

import (
	//"encoding/json"
	"log"
	"strconv"
	"sync"

FZambia

import sys
import math
import uuid
import random
import pprint


def _get_random_game_score():
    max_score = 5
    score1 = score2 = None

FZambia

FZambia

package com.example.fz.centrifugoandroid;

import android.app.Activity;
import android.content.Context;
import android.widget.TextView;

import centrifuge.Message;
import centrifuge.MessageHandler;
import centrifuge.Sub;

FZambia

import UIKit
import Centrifuge

class MessageHandler : NSObject, CentrifugeMessageHandlerProtocol {
    var l: UILabel!
    
    func setLabel(l: UILabel!) {
        self.l = l
    }
    

FZambia

package queue

import (
	"sync"
)

type Item interface {
	Len() int
}

FZambia

package main

import (
	"crypto/tls"
	"fmt"
	"net/http"
	
	"golang.org/x/crypto/acme/autocert"
)

FZambia

/*********************************************************************/
  rtm.worker = false; // тут живёт воркер, если удалось его создать.
  rtm.createWorker = function () {
    if (typeof SharedWorker === 'undefined') {
      return false; // значит, что браузер не умеет такой тип воркеров
    }
    try {
      rtm.worker = new SharedWorker("/rtm/ww.js"); // это урл воркера, его идентификатор
      rtm.worker.port.addEventListener("message", function (msg) {
        rtm.onMessage(msg); // это мой обработчик сообщений от воркера