meejah

from twisted.internet.defer import Deferred, inlineCallbacks, returnValue

d0 = Deferred()
d1 = Deferred()
d2 = Deferred()

def check_value(arg, gold):
    print "check_value", arg, gold
    assert gold == arg

meejah

from twisted.internet.defer import Deferred, inlineCallbacks, returnValue

d0 = Deferred()
d1 = Deferred()
d2 = Deferred()

def check_value(arg, gold):
    print "check_value", arg, gold
    assert gold == arg

meejah

from __future__ import print_function

import pytest

@pytest.hookimpl(hookwrapper=True)
def pytest_fixture_setup(fixturedef, request):
    print("pytest_fixture_setup before", fixturedef, request)
    yield
    print("pytest_fixture_setup after", fixturedef, request)

meejah

import txtorcon
from twisted.internet import defer, task


async def main(reactor):
    tor = await txtorcon.connect(reactor)
    print("tor {}".format(tor))

    state = await tor.create_state()
    print("state {}".format(state))

meejah

class _HashSumProtocol(Protocol):
    def __init__(self, kind='sha256'):
        self._hash = hashlib.new(kind)

    def dataReceived(self, data):
        self.bytes_received += len(data)
        self._hash.update(data)

meejah

from eliot import start_action
from eliot.twisted import DeferredContext
import eliot

from twisted.internet.task import react, deferLater
from twisted.internet.defer import _inlineCallbacks, Deferred


def thing(reactor):
    with start_action(action_type=u"a thing"):

meejah

def do_stuff(arg):
    if arg == 1 or arg == 2:
        return "flarg"
    return "glumphy"

def test_a():
    assert do_stuff(1) == "flarg"

def test_b():

meejah

import asyncio
import aiohttp
from aiosocks.connector import ProxyConnector, ProxyClientRequest


async def fetch(session, socks_port, url):
    conn = ProxyConnector(remote_resolve=True)
    async with aiohttp.ClientSession(connector=conn, request_class=ProxyClientRequest) as session:
        request = session.get(

meejah

# -*- mode: python -*-

from __future__ import print_function

import sys
import functools
from tempfile import mkdtemp
from os.path import dirname, exists, join
from os import mkdir
from StringIO import StringIO

meejah

import asyncio


class Protocol(object):
    def connection_made(self, transport):
        print("connection_made: {}".format(transport))
        transport.abort()

    def connection_lost(self, why):
        print("connection_lost: {}".format(why))