Чтение javax.ws.rs.core.StreamingOutput в клиенте и обработка в процессе его потоковой передачи - PullRequest
0 голосов
/ 26 апреля 2019

Необходимо знать, как обрабатывать StreamingOutput, полученный как ответ от rest-api.

У меня есть rest-api, который возвращает javax.ws.rs.core.StreamingOutput .

Написал клиента, который будет звонить и получать вывод. Я могу получить поток на клиенте.

Код серверной стороны:


StreamingOutput stream = new StreamingOutput() {
                @Override
                public void write(OutputStream os) throws IOException, WebApplicationException {
                    Writer writer = new BufferedWriter (new OutputStreamWriter(os));
                    for (Long i = 1L ; i< 100000L ; i++  ) {
                       writer.write("{"ID":i,"Value":"<random string>"},");
                    }
                    writer.flush();
                }
            };

Ожидаемый поток:

{"ID":1,"Value":"adad"},{"ID":2,"Value":"qwer"},{"ID":3,"Value":"oplr"},...

Невозможно увидеть что-либо вроде объекта StreamingInput или метода чтения в StreamingOutput

Я ищу способ, которым мы можем обработать / понять поток, как он поступает к клиенту .

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...