smurfix

#!/usr/bin/python3

import trio
import outcome
from contextlib import asynccontextmanager

class StreamResultsNursery:
    def __init__(self, max_buffer_size=1):
        self.nursery = trio.open_nursery()
        self.max_buffer_size = max_buffer_size

njsmith

class UniversalQueue:
    def __init__(self, *args, **kwargs):
        self._queue = trio.Queue(*args, **kwargs)
        self._portal = trio.BlockingTrioPortal()
        
    async def trio_get(self):
        return await self._queue.trio_get()
        
    def thread_get(self):
        return self._portal.run(self._queue.trio_get)

mcleonard

import math

class Vector(object):
    def __init__(self, *args):
        """ Create a vector, example: v = Vector(1,2) """
        if len(args)==0: self.values = (0,0)
        else: self.values = args
        
    def norm(self):
        """ Returns the norm (length, magnitude) of the vector """