| 382 | value: float |
| 383 | |
| 384 | class StreamSubject(pw.io.python.ConnectorSubject): |
| 385 | def run(self): |
| 386 | for index in range(offset, offset + nb_rows): |
| 387 | self.next_json({"value": index}) |
| 388 | # Make sure that the data can't be batched |
| 389 | time.sleep(0.01) |
| 390 | self.commit() |
| 391 | |
| 392 | table = pw.io.python.read( |
| 393 | StreamSubject(), |
no outgoing calls