giulioungaretti

t.prefs_.set('color-palette-overrides', ["#ffffff","#d8277f","#17ad98","#dc8a0e","#775dff","#aa33e6","#149bda","#6c696e","#a7a5a8","#d8277f","#17ad98","#dc8a0e","#775dff","#aa33e6","#149bda","#322d34"]);
t.prefs_.set('foreground-color', "#6c696e");
t.prefs_.set('background-color', "#ffffff");
t.prefs_.set('cursor-color', "#6c696e");

giulioungaretti

//
// main.go
// Copyright (C) 2017 unga <giulioungaretti@me.com>
//
// Distributed under terms of the MIT license.
//

package main

import (

giulioungaretti

//
// main.go
package main

import (
	"fmt"
	"net/http"
	"os"

	"github.com/gorilla/securecookie"

giulioungaretti

"""
An XPUB/XSUB broker that forwards subscriptions

"""
import os
import string
import sys
import time
from random import randint
from threading import Thread

giulioungaretti

async def proxy(websocket, path):
    while True:
        log = await zmqsocket.recv_multipart()
        await websocket.send(log[1])

giulioungaretti

#! /usr/bin/env python
# -*- coding: utf-8 -*-
# vim:fenc=utf-8
#
# Copyright © 2016 unga <giulioungaretti@me.com>
#
# Distributed under terms of the MIT license.

"""
Benchamrk mp queues

giulioungaretti

• Update HISTORY.rst
• Commit the changes:

git add HISTORY.rst
git commit -m "Changelog for upcoming release 0.1.1."

• Update version number (can also be minor or major)

bumpversion patch

giulioungaretti

class DotDict(dict):
    """
    wrap dict so merlin is happy
    """
    def __init__(self, value=None):
        if value is None:
            pass
        else:
            for key in value:
                self.__setitem__(key, value[key])

giulioungaretti

    def _set_async(self, value):
        with futures.ThreadPoolExecutor(max_workers=self.no_instruments+10) as executor:
            jobs = []
            for i in self._instrument_list:
                job = executor.submit(partial(i.set, 'x'), value)
                jobs.append(job)

        futures.wait(jobs) 

giulioungaretti

    def _set_async(self, value):
        with futures.ThreadPoolExecutor(max_workers=self.no_instruments+10) as executor:
            jobs = []
            for i in self._instrument_list:
                job = executor.submit(partial(i.set, 'x'), value)
                jobs.append(job)

        futures.wait(jobs)