(self, output_stream)
| 59 | yield np.asarray(x) * i |
| 60 | |
| 61 | def encode_response(self, output_stream): |
| 62 | for output in output_stream: |
| 63 | output = list(output) |
| 64 | yield [{"output": o} for o in output] |
| 65 | |
| 66 | |
| 67 | def test_default_batch_unbatch(): |
no outgoing calls
no test coverage detected