(redis, base_key)
| 94 | |
| 95 | |
| 96 | def _stream_ready(redis, base_key): |
| 97 | offset = 0 |
| 98 | chunks_key = _chunks_key(base_key) |
| 99 | while True: |
| 100 | chunk = redis.lindex(chunks_key, offset) |
| 101 | if chunk is None: |
| 102 | break |
| 103 | yield _decode_chunk(chunk) |
| 104 | offset += 1 |
| 105 | |
| 106 | |
| 107 | def _stream_build(redis, base_key, source, cache_ttl, lock_ttl): |
no test coverage detected