Здравствуйте, f95.2, Вы писали:

F2>Как в джаве принято такое делать? Писать свой класс потока?

Есть не пугает работа с Threads, то можно изпользовать PipedReader/PipedWriter (или PipedInputStream/PipedOutputStream). Они связываются через метод connect() любого из объектов и становятся чем-то вроде Unix pipes, то есть читатель автоматически блокируется, если данных нет. С помощью адаптеров из Channels можно оборачивать ReadableByteChannel и WritableByteChannel.