Did I find the right examples for you? yes no

All Samples(8)  |  Call(2)  |  Derive(3)  |  Import(3)

src/f/s/fshttpstream-HEAD/src/fshttpstream/queueinboundsocket.py   fshttpstream(Download)
# -*- coding: utf-8 -*-
import gevent
import gevent.queue
from telephonie.core.inboundsocket import InboundEventSocket
from telephonie.core.errors import ConnectError
from telephonie.utils.logger import StdoutLogger
 
 
class QueueInboundEventSocket(InboundEventSocket):

src/f/s/fshttpstream-0.3.4/fshttpstream/queueinboundsocket.py   fshttpstream(Download)
# -*- coding: utf-8 -*-
import gevent
import gevent.queue
from telephonie.core.inboundsocket import InboundEventSocket
from telephonie.core.errors import ConnectError
from telephonie.utils.logger import StdoutLogger
 
 
class QueueInboundEventSocket(InboundEventSocket):

src/t/e/telephonie-0.3.1/src/tests/test_inboundsocket.py   telephonie(Download)
# -*- coding: utf-8 -*-
from unittest import TestCase
 
from telephonie.core.inboundsocket import InboundEventSocket
from telephonie.core.eventtypes import Event
class TestInboundEventSocket(InboundEventSocket):
    def __init__(self, host, port, password, filter='ALL', pool_size=500, connect_timeout=5):
        InboundEventSocket.__init__(self, host, port, password, filter, pool_size, connect_timeout)
        self.heartbeat_events = []
        self.re_schedule_events = []
    def test_login_failure(self):
        isock = InboundEventSocket('127.0.0.1', 23333, 'ClueCon')
        self.assertRaises(ConnectError, isock.connect)
 
    def test_login_success(self):
        isock = InboundEventSocket('127.0.0.1', 18021, 'ClueCon')