(self, cfg, source, source_addr)
| 21 | mesg_class = None |
| 22 | |
| 23 | def __init__(self, cfg, source, source_addr): |
| 24 | self.cfg = cfg |
| 25 | if hasattr(source, "recv"): |
| 26 | self.unreader = SocketUnreader(source) |
| 27 | else: |
| 28 | self.unreader = IterUnreader(source) |
| 29 | self.mesg = None |
| 30 | self.source_addr = source_addr |
| 31 | |
| 32 | # request counter (for keepalive connetions) |
| 33 | self.req_count = 0 |
| 34 | |
| 35 | def __iter__(self): |
| 36 | return self |
nothing calls this directly
no test coverage detected