Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(5)  |  Call(3)  |  Derive(0)  |  Import(2)

src/c/o/concurrence-HEAD/lib/concurrence/__init__.py   concurrence(Download)
from concurrence.core import dispatch, quit, disable_threading, get_version_info
from concurrence.core import Channel, Tasklet, Message, FileDescriptorEvent, SignalEvent
from concurrence.core import TimeoutError, TaskletError, JoinError
from concurrence.local import TaskLocal, TaskInstance

src/r/t/rtjp-0.2.1/rtjp/concurrence.py   rtjp(Download)
from __future__ import absolute_import
from concurrence import dispatch, Tasklet, Message
from concurrence.io import BufferedStream, Socket, Server
from concurrence.core import Channel
    def __init__(self):
        self._channel = Channel()
    def send(self, arg, block=False):
        if not block and not self._channel.has_receiver():
    def __init__(self):
        self._sock = None
        self._accept_channel = Channel()
    def listen(self, port, interface=""):
    def __init__(self, sock, delimiter='\r\n'):
        self._sock = sock
        self.frame_id = 0
        self.stream = BufferedStream(sock)
        self._frame_channel = Channel()