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

All Samples(95)  |  Call(28)  |  Derive(21)  |  Import(46)

src/s/t/stream.py-HEAD/example/pi.py   stream.py(Download)
 
from decimal import Decimal, getcontext
from stream import Stream, Processor, seq, gseq, apply, map, fold, zip, item, drop
 
"""
class recur_transform(Stream):
	"""Apply a accelerator recursively."""
	def __init__(self, accelerator):
		super(recur_transform, self).__init__()
		self.accelerator = accelerator

src/s/t/stream-0.8/example/pi.py   stream(Download)
 
from decimal import Decimal, getcontext
from stream import Stream, Processor, seq, gseq, apply, map, fold, zip, item, drop
 
"""
class recur_transform(Stream):
	"""Apply a accelerator recursively."""
	def __init__(self, accelerator):
		super(recur_transform, self).__init__()
		self.accelerator = accelerator

src/s/p/spdypy-HEAD/spdypy/connection.py   spdypy(Download)
import select
import zlib
from .stream import Stream
from .frame import from_bytes
from .data import SPDY_3_ZLIB_DICT
        # ID.
        stream_id = self._next_stream_id
        stream = Stream(stream_id,
                        version=3,
                        compressor=self._compressor,

src/p/y/pyfire-0.3.4/pyfire/room.py   pyfire(Download)
from .entity import CampfireEntity
from .message import Message
from .stream import Stream
from .upload import Upload
 
        """
        self.join()
        return Stream(self, error_callback=error_callback, live=live)
 
    def get_uploads(self):

src/p/y/pyfire-HEAD/pyfire/room.py   pyfire(Download)
from .entity import CampfireEntity
from .message import Message
from .stream import Stream
from .upload import Upload
 
        """
        self.join()
        return Stream(self, error_callback=error_callback, live=live)
 
    def get_uploads(self):

src/h/y/hyper-HEAD/hyper/http20/connection.py   hyper(Download)
"""
from .hpack import Encoder, Decoder
from .stream import Stream
from .tls import wrap_socket
from .frame import (
        window_size = self._settings[SettingsFrame.INITIAL_WINDOW_SIZE]
        s = Stream(
            stream_id or self.next_stream_id, self._send_cb, self._recv_cb,
            self._close_stream, self.encoder, self.decoder,
            self.__wm_class(65535), local_closed

src/g/r/griffonbot-HEAD/main.py   griffonbot(Download)
 
from log import Log
from stream import Stream
from bot import IRCBot
from daemon import wait
 
  if config.twitter.enable:
    stream = Stream(config.twitter, bot.queue_message, log)
 
  if config.mail.enable:

src/g/r/grokpy-0.2.17/grokpy/client.py   grokpy(Download)
from model import Model
from model_specification import ModelSpecification
from stream import Stream
from stream_specification import StreamSpecification
from exceptions import GrokError
    result = self.c.request('POST', url, requestDef)
 
    return Stream(parent, result['stream'])
 
  def getStream(self, streamId, url = None):
    streamDef = rv['stream']
 
    return Stream(self, streamDef)
 
  def listStreams(self, url = None):
    streams = []
    for streamDef in self.c.request('GET', url, params = params)['streams']:
      streams.append(Stream(self, streamDef))
 
    return streams

src/a/e/Aerospace-Simulations-HEAD/morse/bindings/pymorse/src/pymorse/pymorse.py   Aerospace-Simulations(Download)
 
 
from .stream import Stream
 
class MorseServerError(Exception):
 
        if stream == 'IN':
            self.stream = Stream(self._morse.com, port)
            self.publish = self.stream.publish
        elif stream == 'OUT':
            self.stream = Stream(self._morse.com, port)

src/p/y/pymorse-1.2/src/pymorse/pymorse.py   pymorse(Download)
 
from .future import MorseExecutor
from .stream import Stream, StreamJSON
 
logger = logging.getLogger("pymorse")
        """
        self.host = host
        self.simulator_service = Stream(host, port)
        self.simulator_service_id = 0
        if not Morse._asyncore_thread:

  1 | 2 | 3 | 4 | 5  Next