can receive and unframe connectionstart
Showing
- coolamqp/__init__.py 1 addition, 0 deletionscoolamqp/__init__.py
- coolamqp/connection/definition.py 27 additions, 0 deletionscoolamqp/connection/definition.py
- coolamqp/framing/compilation/compile_definitions.py 40 additions, 40 deletionscoolamqp/framing/compilation/compile_definitions.py
- coolamqp/framing/compilation/textcode_fields.py 2 additions, 0 deletionscoolamqp/framing/compilation/textcode_fields.py
- coolamqp/framing/definitions.py 113 additions, 276 deletionscoolamqp/framing/definitions.py
- coolamqp/framing/field_table.py 4 additions, 4 deletionscoolamqp/framing/field_table.py
- coolamqp/framing/frames.py 8 additions, 3 deletionscoolamqp/framing/frames.py
- coolamqp/uplink/__init__.py 4 additions, 0 deletionscoolamqp/uplink/__init__.py
- coolamqp/uplink/connection/__init__.py 11 additions, 0 deletionscoolamqp/uplink/connection/__init__.py
- coolamqp/uplink/connection/connection.py 58 additions, 0 deletionscoolamqp/uplink/connection/connection.py
- coolamqp/uplink/connection/recv_framer.py 33 additions, 31 deletionscoolamqp/uplink/connection/recv_framer.py
- coolamqp/uplink/connection/send_framer.py 47 additions, 0 deletionscoolamqp/uplink/connection/send_framer.py
- coolamqp/uplink/listener/__init__.py 17 additions, 0 deletionscoolamqp/uplink/listener/__init__.py
- coolamqp/uplink/listener/epoll_listener.py 91 additions, 0 deletionscoolamqp/uplink/listener/epoll_listener.py
- coolamqp/uplink/listener/socket.py 97 additions, 0 deletionscoolamqp/uplink/listener/socket.py
- coolamqp/uplink/listener/thread.py 40 additions, 0 deletionscoolamqp/uplink/listener/thread.py
- coolamqp/uplink/order.py 0 additions, 30 deletionscoolamqp/uplink/order.py
- coolamqp/uplink/reactor.py 35 additions, 0 deletionscoolamqp/uplink/reactor.py
- coolamqp/uplink/reader_thread.py 0 additions, 34 deletionscoolamqp/uplink/reader_thread.py
- coolamqp/uplink/watchman.py 0 additions, 144 deletionscoolamqp/uplink/watchman.py
Loading
Please register or sign in to comment