(self, value: torch.Tensor)
| 112 | class TokensIteratorStreamer(StreamerMixin, BaseStreamer): |
| 113 | |
| 114 | def put(self, value: torch.Tensor) -> None: |
| 115 | self.queue.put(value) |
| 116 | |
| 117 | def end(self) -> None: |
| 118 | self.queue.put(None) |
no outgoing calls
no test coverage detected