(sockets, remain=conf.recv_poll_rate)
| 262 | |
| 263 | @staticmethod |
| 264 | def select(sockets, remain=conf.recv_poll_rate): |
| 265 | # type: (List[SuperSocket], Optional[float]) -> List[SuperSocket] |
| 266 | # Only handle ObjectPipes |
| 267 | results = [] |
| 268 | for s in sockets: |
| 269 | if s.closed: # allow read to trigger EOF |
| 270 | results.append(s) |
| 271 | if results: |
| 272 | return results |
| 273 | return select_objects(sockets, remain) |
| 274 | |
| 275 | |
| 276 | class Message: |
no test coverage detected