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

All Samples(27)  |  Call(0)  |  Derive(20)  |  Import(7)

src/c/o/concurrence-HEAD/examples/chat.py   concurrence(Download)
from concurrence import dispatch, Tasklet, Message
from concurrence.io import BufferedStream, Socket, Server
 
class MSG_WRITE_LINE(Message): pass
class MSG_QUIT(Message): pass
class MSG_LINE_READ(Message): pass

src/c/o/concurrence-HEAD/examples/message.py   concurrence(Download)
from concurrence import Tasklet, Message, dispatch
 
class MSG_GREETING(Message): pass
class MSG_FAREWELL(Message): pass
 

src/c/o/concurrence-HEAD/lib/concurrence/http/server.py   concurrence(Download)
import rfc822
 
from concurrence import Tasklet, Message, Channel, TimeoutError, __version__
from concurrence.io import Server, BufferedStream
from concurrence.containers import ReorderQueue
    class MSG_REQUEST_HANDLED(Message): pass
    class MSG_WRITE_RESPONSE(Message): pass
    class MSG_RESPONSE_WRITTEN(Message): pass
    class MSG_REQUEST_READ(Message): pass
    class MSG_READ_ERROR(Message): pass

src/c/o/concurrence-HEAD/lib/concurrence/http/client.py   concurrence(Download)
import logging
 
from concurrence import Tasklet, Channel, Message, __version__
from concurrence.timer import Timeout
from concurrence.io import Connector, BufferedStream

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
 

src/c/o/concurrence-HEAD/test/testremote.py   concurrence(Download)
from concurrence import unittest, Message, Tasklet, TimeoutError
from concurrence.remote import RemoteServer, RemoteTasklet, RemoteClient
 
import logging
 
#we need to define the msgs at the module level
#otherwise the remoting cannot use pickle to serialize them
class MSG_TEST(Message): pass
class MSG_SUM(Message): pass
class MSG_QUIT(Message): pass
class MSG_SLEEP(Message): pass
 
class RemoteTest(unittest.TestCase):
 
    def testRemote(self):

src/c/o/concurrence-HEAD/test/testcore.py   concurrence(Download)
import sys
 
from concurrence import unittest, Tasklet, Channel, TimeoutError, TaskletError, JoinError, Message
 
class TestTasklet(unittest.TestCase):
        class MSG_PONG(Message): pass
        class MSG_PING(Message): pass
 
        def c(parent):
            for msg, args, kwargs in Tasklet.receive():     
        class MSG_TEST_SUM(Message): pass
        class MSG_TEST_MAX(Message): pass
        class MSG_TEST_SLEEP(Message): pass