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

All Samples(15)  |  Call(1)  |  Derive(0)  |  Import(14)

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

src/c/o/concurrence-HEAD/lib/concurrence/database/pool.py   concurrence(Download)
import time
 
from concurrence import TimeoutError, Channel, Tasklet
from concurrence.containers import Deque
from concurrence.timer import Timeout

src/c/o/concurrence-HEAD/lib/concurrence/web/filter.py   concurrence(Download)
 
from concurrence.web import Filter
from concurrence import json, TimeoutError
 
class JSONFilter(Filter):

src/c/o/concurrence-HEAD/lib/concurrence/database/mysql/dbapi.py   concurrence(Download)
from datetime import datetime
from concurrence.database.mysql import client
from concurrence import TimeoutError as ConcurrenceTimeoutError
 
threadsafety = 1

src/c/o/concurrence-HEAD/lib/concurrence/database/mysql/client.py   concurrence(Download)
#TODO supporting closing a halfread resultset (e.g. automatically read and discard rest)
 
from concurrence import TimeoutError
from concurrence.io import Buffer 
from concurrence.io.socket import Socket 

src/c/o/concurrence-HEAD/test/testweb.py   concurrence(Download)
# -*- coding: utf-8 -*-
 
from concurrence import unittest, Tasklet, TimeoutError
 
from concurrence.web import Application, Controller, Filter, web
    def timeout(self):
        Tasklet.sleep(2.0)
        raise TimeoutError() #simulate it because sleep does not honor timeouts
 
    @web.route('/json')

src/c/o/concurrence-HEAD/test/testtimer.py   concurrence(Download)
from __future__ import with_statement
 
import time
 
from concurrence import unittest, Tasklet, Channel, TimeoutError

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
 

src/c/o/concurrence-HEAD/test/testpool.py   concurrence(Download)
from __future__ import with_statement
 
import time
 
from concurrence import dispatch, unittest, Tasklet, TimeoutError

src/c/o/concurrence-HEAD/test/testmysql.py   concurrence(Download)
        rs.close()
 
        from concurrence import TimeoutError
        from concurrence.timer import Timeout
 

  1 | 2  Next