cefn

from threading import Thread
from time import sleep

from twisted.trial.unittest import TestCase
from twisted.internet.defer import Deferred
from twisted.internet import reactor

class ThreadTestCase(TestCase):

    def setUp(self):

cefn

var Bacon = require("baconjs"),
    assert = require("assert");

require('promise.prototype.finally');

describe("Testing stream equality logic", function(){

    it( "can match Bacon streams backed by the same array.", function(){
        var targetSequence = [
            ["oldmacdonald/farm", "['sheep','pig','cow','duck']" ] , //n.b. JSON.stringify of array

cefn

var Bacon = require("baconjs"),
    assert = require("assert");

require('promise.prototype.finally');

describe("Testing stream equality logic", function(){

    it( "can match Bacon streams backed by the same array.", function(){
        var targetSequence = [
            ["oldmacdonald/farm", "['sheep','pig','cow','duck']" ] , //n.b. JSON.stringify of array

cefn

/** Verifies that the over-the-wire MQTT messages arising from IdeaTree operations are as expected. */
        describe("Tree Protocol", function(){
            it("Sends branch keys then leaf values", function(){

                var sniffer = mqtt.connect(conf.mqttWsAddr);

                var subscribeAndSendPromise = util.createSubscriptionPromise(sniffer, '#')
                    .then(function(){
                        writer.setItem('oldmacdonald/farm', {
                            sheep:"Baa",

cefn

/** Verifies that the over-the-wire MQTT messages arising from IdeaTree operations are as expected. */
describe("Tree Protocol", function(){
it("Sends branch keys then leaf values", function(){

    var sniffer = mqtt.connect(conf.mqttWsAddr);

    var subscribeAndSendPromise = util.createSubscriptionPromise(sniffer, '#')
        .then(function(){
            writer.setItem('oldmacdonald/farm', {
                sheep:"Baa",

cefn

"use strict";
var _ = require("lodash"),
    Kefir = require("kefir"),
    events = require("events");

/** This Gist is intended to emulate an eventing framework in which Javascript objects
 * containing topic:value pairs are kept in synchrony across a network.
 *
 * There is a mysterious problem, in which a flatMap actually triggered by a Property event
 * creates a stream which is also based on the same Property, but which doesn't seem to generate events.

cefn

"use strict";
var Kefir = require("kefir"),
    events = require('events');

var empty = void(0);

var localEmitter = new events.EventEmitter(); //used to notify local updates to values against new or old topics
var remoteEmitter = new events.EventEmitter(); //used to notify local updates to values against new or old topics

var localProperty = Kefir.fromEvents(localEmitter, "Hello").toProperty();

cefn

var Q = require("q");
var persistence = require("persistence");
var mosca = require("mosca");
var mqtt = require("mqtt");
var chai = require("chai");

var should = chai.should();
var Promise = Q.Promise;

function promiseServer(){

cefn

var Q = require("q");
var persistence = require("persistence");
var mosca = require("mosca");
var mqtt = require("mqtt");
var chai = require("chai");

var should = chai.should();
var Promise = Q.Promise;

function promiseServer(){

cefn

var chai = require("chai"),
    chaiAsPromised = require("chai-as-promised"),
    selenium = require("selenium-standalone"),
    wd = require("wd"),
    Q=require("q");

chai.use(chaiAsPromised);
chai.should();
chaiAsPromised.transferPromiseness = wd.transferPromiseness;