У меня есть одна готовая программа, которая принимает текстовые данные в виде InputStream. Я смотрел код -- внутри она от этого InputStream in формирует new BufferedReader(new InputStreamReader(in)) и потом для получившегося вызывает readLine.

У меня есть вторая программа, которая выдаёттекстовые данные в виде строк String.

Мне надо подать выход второй программы на вход первой.

Я подумал, что смогу завернуть вторую программу в класс extends InputStream (реализовав метод read) и всё получится. 

Написал так:



Я думал, что встретив символ новой строки, обёртки потока прекратят чтение до следующего вызова readLine. Но не тут-то было. Судя по отладчику, после того, как этот метод возвращает символ новой строки, он вызывается снова и снова, а возврата из метода readLine не происходит.

Судя по всему, какой-то промежуточный слой занимается буферизацией, то есть, где-то считывает, скажем, 1024 символа и уж потом собирается вернуть первую строку.

Вопрос -- как этого избежать? Как сделать, чтобы readLine возвращал строки в той же разбивке, в которой я их формирую?

Добавлено через 10 минут и 56 секунд
P.S. Забыл сказать, что переменная buffer определена так:

private StringBuilder buffer = new StringBuilder();

(это член класса, в который я заворачиваю выдающую программу)

Это сообщение отредактировал(а) Dims - 18.9.2009, 19:27

Код, который принимает вывод у второй программы и запихивает в буфер?
Вобщем решение такое: в топку буфер, первая программа сразу читает вывод второй, т. к. read() - блокирующий вызов. Все нюансы такого чтения в этом самом наследнике InputStream.
?

Полностью код выглядит так:




Здесь видно, что для получения строки, я должен сделать сначала

Result result = recognizer.recognize()

а потом

result.getBestFinalResultNoFiller()

И я получу строку. Как мне это направить на вход?

Да по всякому можно.

Как то так. Надо ещё определится с концом вывода второй программы.

Чем это принципиально отличается от того, что у меня? Наверняка то же самое будет происходить.

Я предполагал, что вывод второй программы существует в виде InputStream. Во вторых не надо содержимое буфера сдвигать каждый раз. В третьих - если метод recognizer.recognize(); не блокирующий - то код выше тоже в топку и искать способы синхронизации в выводом второй программы.

Скорее всего, внутри StringBuilder находится двусвязный список и на сдвиг затрат не происходит.


А что это означает?

Я то, убедился, прежде чем написал. 

Поток, в котором произошел вызов метода, блокируется (выполнение приостанавливается) до получения результата.

Не понимаю, какую это может иметь роль? Функция возвращает строку -- работай с этой строкой. Почему работа происходит неправильно?

Я переписал метод вот так (пока фиг с ним со StringBuilder):



а вызов происходит вот так



и я вижу, что сперва выводится куча раз

line added in read

и только потом начинает выводиться

Hello World!

Как от этого избавиться?

А не проще ли будет сделать как советует сан?



и дальше передавать его. 


Ну если уж очень сильно хочется, то есть класс StringBufferInputStream  -- но он после 1.4.2 обьявлен Deprecated




Это сообщение отредактировал(а) Akeem - 19.9.2009, 09:50

Может и проще, но мне теперь уже непонятна логика происходящего и хочется разобраться. 

Если я в качестве потока использую System.in, то всё работает как надо, то есть, readLine читает из потока только одну строку и сразу же её возвращает, как только встретился символ новой строки. Если же я в качестве входного потока даю свой поток, то почему-то readLine не останавливается на первом символе НС, а продолжает читать дальше, пока не заполнит буфер.

Естественно, возвращает он в обоих случаях только одну первую строку, но считывает в разных случаях разное. Мне непонятно, почему. И как я могу воспроизвести поведение System.in в своём классе.

Разобрался.