(self, socket, delimiter="\n", format=lambda s: s, **kwargs)
| 1526 | class TwitterStream(Stream): |
| 1527 | |
| 1528 | def __init__(self, socket, delimiter="\n", format=lambda s: s, **kwargs): |
| 1529 | kwargs.setdefault("timeout", 30) |
| 1530 | Stream.__init__(self, socket, delimiter, **kwargs) |
| 1531 | self.format = format |
| 1532 | |
| 1533 | def parse(self, data): |
| 1534 | """ TwitterStream.queue will populate with Result objects as |
nothing calls this directly
no test coverage detected