listener.Listener

All Samples(26) | Call(8) | Derive(6) | Import(12)

src/c/a/Cactus_Refactored-HEAD/cactus/site.py Cactus_Refactored(Download)

                self.listener.resume()
 
        from .listener import Listener
 
        self.listener = Listener(
            self.path, rebuild, ignore=lambda x: '/.tmp/' in x

src/c/a/Cactus-2.3.1/cactus/site.py Cactus(Download)

from .utils import *
from .page import Page
from .listener import Listener
from .file import File
from .server import Server, RequestHandler

			self.listener.resume()
 
		self.listener = Listener(self.path, rebuild, ignore=lambda x: '/.build/' in x)
		self.listener.run()

src/c/a/Cactus-HEAD/cactus/site.py Cactus(Download)

from .utils import *
from .page import Page
from .listener import Listener
from .file import File
from .server import Server, RequestHandler

			self.listener.resume()
 
		self.listener = Listener(self.path, rebuild, ignore=lambda x: '/.build/' in x)
		self.listener.run()

src/k/i/KiTT-1.1/kitt/kitt.py KiTT(Download)

        from kivy.base import EventLoop, runTouchApp, stopTouchApp
        from kivy.support import install_gobject_iteration
        from listener import Listener
 
        listener = Listener(args.config, args.gestures, EventLoop)

src/r/o/Rocket-1.2.4/rocket/main.py rocket(Download)

from .threadpool import ThreadPool
from .worker import get_method
from .listener import Listener
 
# Setup Logging

 
        # Build our socket listeners
        self.listeners = [Listener(i, queue_size, self.active_queue) for i in self.interfaces]
        for ndx in range(len(self.listeners)-1, 0, -1):
            if not self.listeners[ndx].ready:

src/m/m/mmlx-1.0.2/mmlxlib/musicbox.py mmlx(Download)

from util import Util
from instrument import Instrument
from listener import Listener
from logger import Logger

        self.logger = Logger(self.options)
 
        listener = Listener(self.logger)
        listener.onChange(self.processFile)

src/a/c/AccordionMega-HEAD/rtmidi/pkaudio/scosc/controller.py AccordionMega(Download)

 
        self.incoming = Queue.Queue()
        self.listener = listener.Listener(self.socket)
        self.listener.register(None, self.incoming.put)
        if verbose:

src/t/h/thriftworker-0.2.10/thriftworker/app.py thriftworker(Download)

from .transports.base import Acceptors
from .state import set_current_app, get_current_app
from .listener import Listener, Listeners
from .hub import Hub
from .services import Services

src/d/r/drench-0.0.13/drench/drench.py drench(Download)

import json
from string import ascii_letters, digits
from listener import Listener
from switchboard import Switchboard

class PeerListener(Listener):
    def __init__(self, address='127.0.0.1',
                 port=7000, torrent=None):
        Listener.__init__(self, address, port)
        self.torrent = torrent

class VisListener(Listener):
    def __init__(self, address='127.0.0.1',
                 port=8035, torrent=None):
        Listener.__init__(self, address, port)
        assert torrent

src/d/r/drench-HEAD/drench/drench.py drench(Download)

import json
from string import ascii_letters, digits
from listener import Listener
from switchboard import Switchboard

class PeerListener(Listener):
    def __init__(self, address='127.0.0.1',
                 port=7000, torrent=None):
        Listener.__init__(self, address, port)
        self.torrent = torrent

class VisListener(Listener):
    def __init__(self, address='127.0.0.1',
                 port=8035, torrent=None):
        Listener.__init__(self, address, port)
        assert torrent

1 | 2 Next