Как скопировать/буферизировать бесконечный InputStream?

Question

[pinegink1]

Есть InputStream и в него бесконечно поступают данные. Необходимо эти данные раздать на множество OutputStream'ов

Answer 1

[Dmitry Roo]

У InputStream есть метод read(byte[] b): им читаете нужное количество байт.
Потом этот массив байт раскладываете в outputStream-ы в любом количестве.

Comments

[pinegink1]

Пытаюсь таким образом раздавать mpeg. Если написать inputStream.transferTo(outputStream) - работает, но только для одного клиента.

При использовании byte[] b как буфера - не работает. Но не понимаю почему

[pinegink1]

Не так. Информация вроде передается, но все падает с IOException: программа на вашем хост-компьютере разорвала установленное подключение.
try-catch почему-то не ловит его

[Dmitry Roo]

Пример бы кода посмотреть...

[pinegink1]

Dmitry Roo, https://github.com/pinegink/proxy/blob/master/src/...
проблема с exception костылем, но решается вроде
самое странное, что данные не обновляются - видно при установке if
UPD: работает, но сделано криво - подобран тыком размер буфера и время sleep. Наверное, есть лучше решение