mivade

"""Simple demonstration of using ZMQ's Curve authentication.

This demo is adapted from the examples given in the `PyZMQ repository`__. Key
differences include:

* Using ``setsockopt`` to set Curve parameters instead of setting attributes
  directly (help out your IDE!)
* Integration with ``asyncio``

__ https://github.com/zeromq/pyzmq/tree/master/examples

mivade

import asyncio
from pathlib import Path
from typing import Optional

from watchdog.events import FileSystemEvent, FileSystemEventHandler
from watchdog.observers import Observer


class _EventHandler(FileSystemEventHandler):
    def __init__(self, queue: asyncio.Queue, loop: asyncio.BaseEventLoop,

mivade

import codecs
import json
from typing import Union

import h5py
import numpy as np
import pandas as pd

vlen = np.vectorize(len)
vencode = np.vectorize(codecs.encode)

mivade

class Manager(object):
    classes = set()


class Meta(type):
    def __new__(cls, name, bases, d):
        print("name:", name, "\nbases:", bases, "\ndict: ", d)
        if name is not "Base":
            Manager.classes.add(d['data'])
        return type.__new__(cls, name, bases, d)

mivade

from multiprocessing import Event, Process, Queue
import time
import zmq


class BaseActor(Process):
    ready = Event()

    def handle(self, msg):
        print("dt =", time.time() - msg['timestamp'])

mivade

import asyncio
from threading import Event, Thread


class EventLoopThread(Thread):
    def __init__(self):
        super().__init__()
        self.loop = None
        self.ready = Event()

mivade

import sys
from PyQt5.QtWidgets import *
from PyQt5.QtGui import *


class MainWindow(QWidget):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)

        self.setWindowTitle('Multiline lambdas')

mivade

Keybase proof

I hereby claim:

• I am mivade on github.
• I am mivade (https://keybase.io/mivade) on keybase.
• I have a public key ASCjifbgjSNGV_4F5Ge6JtJZBHGMNpi4miYvMDbZUbD1Fwo

To claim this, I am signing this object:

mivade

mivade

"""Examples of how to bind a socket to a random port and have that port number
accessible to other processes. Useful for interprocess communications.

"""

import time
import socket
from socket import AF_INET, SOCK_STREAM
from multiprocessing import Process, Queue, Event
from contextlib import contextmanager