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

All Samples(48)  |  Call(27)  |  Derive(0)  |  Import(21)
The manager class has two roles. As a base class for component
implementation, it provides methods for event and handler management.
The method :meth:`.fireEvent` appends a new event at the end of the event
queue for later execution. :meth:`.waitEvent` suspends the execution
of a handler until all handlers for a given event have been invoked.
:meth:`.callEvent` combines the last two methods in a single method.

The methods :meth:`.addHandler` and :meth:`.removeHandler` allow handlers
for events to be added and removed dynamically. (The more common way to
register a handler is to use the :func:`~.handlers.handler` decorator(more...)

src/c/i/circuits-3.0.0.dev/examples/hello_bridge.py   circuits(Download)
from os import getpid
 
from circuits import Component, Debugger, Event, Manager
 
 
 
 
m = Manager() + Debugger()
m.start()
App().start(process=True, link=m)

src/c/i/circuits-3.0.0.dev/examples/testing/pytest/conftest.py   circuits(Download)
 
from circuits.core.manager import TIMEOUT
from circuits import handler, BaseComponent, Debugger, Manager
 
 
def manager(request):
    manager = Manager()
 
    def finalizer():
        manager.stop()

src/c/i/circuits-3.0.0.dev/circuits/web/main.py   circuits(Download)
from circuits.core.pollers import Select
from circuits.tools import inspect, graph
from circuits import Component, Manager, Debugger
from circuits import __version__ as systemVersion
 
        raise SystemExit(0)
 
    manager = Manager()
 
    if opts.debug:

src/k/d/kdb-1.0.2/kdb/main.py   kdb(Download)
 
from circuits.app import Daemon
from circuits import Debugger, Manager, Worker
 
 
    config = Config()
 
    manager = Manager()
 
    Worker(channel="workerthreads").register(manager)

src/s/p/spring-python-HEAD/src/springpython/jms/listener.py   spring-python(Download)
 
# Circuits
from circuits import Component, Manager, Debugger
 
# ThreadPool
        for idx in range(self.concurrent_listeners):
            # Create as many Circuits managers as there are JMS listeners.
            manager = Manager()
            manager.start()
 

src/s/p/springpython-1.3.0.RC1/springpython/jms/listener.py   springpython(Download)
 
# Circuits
from circuits import Component, Manager, Debugger
 
# ThreadPool
        for idx in range(self.concurrent_listeners):
            # Create as many Circuits managers as there are JMS listeners.
            manager = Manager()
            manager.start()
 

src/s/a/sahriswiki-0.8.1/sahriswiki/main.py   sahriswiki(Download)
 
from circuits.app import Daemon
from circuits import Manager, Debugger
 
try:
def main():
    config = Config()
 
    manager = Manager()
 

src/c/i/circuits-3.0.0.dev/tests/net/test_unix.py   circuits(Download)
    pytest.skip("Test Not Applicable on Windows")
 
from circuits import Manager
from circuits.net.sockets import close, connect, write
from circuits.net.sockets import UNIXServer, UNIXClient
def test_unix(tmpdir, Poller):
    m = Manager() + Poller()
 
    sockpath = tmpdir.ensure("test.sock")
    filename = str(sockpath)

src/c/i/circuits-3.0.0.dev/tests/net/test_udp.py   circuits(Download)
import select
 
from circuits import Manager
from circuits.core.events import unregister
from circuits.net.events import close, write
def test_basic(Poller, ipv6):
    m = Manager() + Poller()
 
    if ipv6:
        udp_server = UDP6Server(("::1", 0))
def test_close(Poller, ipv6):
    m = Manager() + Poller()
    server = Server() + UDPServer(0)
    server.register(m)
    m.start()

src/c/i/circuits-3.0.0.dev/tests/net/test_tcp.py   circuits(Download)
from socket import socket, AF_INET, AF_INET6, SOCK_STREAM, has_ipv6
 
from circuits import Manager
from circuits.net.events import close, connect, write
from circuits.core.pollers import Select, Poll, EPoll, KQueue
def test_tcp_basic(Poller, ipv6):
    m = Manager() + Poller()
 
    if ipv6:
        tcp_server = TCP6Server(("::1", 0))
        pytest.skip("Broken on Windows on Python 3.2")
 
    m = Manager() + Poller()
 
    if ipv6:
        pytest.skip("Broken on Windows")
 
    m = Manager() + Poller()
    if ipv6:
        tcp_server = TCP6Server(("::1", 0))
def test_tcp_bind(Poller, ipv6):
    m = Manager() + Poller()
 
    if ipv6:
        sock = socket(AF_INET6, SOCK_STREAM)

  1 | 2 | 3  Next