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

All Samples(2)  |  Call(0)  |  Derive(0)  |  Import(2)

src/a/m/amqp-HEAD/client.py   amqp(Download)
from connection import Connection as ProtoConnection, ConnectionError
from sasl import SASL
from session import Session as ProtoSession, SessionError, FIXED, SLIDING
from link import Link as ProtoLink, Sender as ProtoSender, \
    Receiver as ProtoReceiver, LinkError, link

src/a/m/amqp-HEAD/brokerlib.py   amqp(Download)
from connection import Connection
from sasl import SASL
from session import Session, SessionError, FIXED
from link import LinkError, Receiver, Sender, link
from util import ConnectionSelectable
  def timeout(self, connection):
    for ssn in connection.incoming.values() + connection.outgoing.values():
      ssn.set_incoming_window(self.window, FIXED)
 
  def tick(self, connection):
        ssn.begin()
        if self.period:
          ssn.set_incoming_window(self.window, FIXED)
        else:
          ssn.set_incoming_window(self.window)
        ssn.begin()
        if self.period:
          ssn.set_incoming_window(self.window, FIXED)
        else:
          ssn.set_incoming_window(self.window)