Я использую Netty HttpChunkedInput для записи ChunkedStream, которая, в свою очередь, использует пользовательскую реализацию InputStream, которая может блокироваться, поскольку она получает данные с серверов других узлов.Вот строка, которая записывает это:
ctx.writeAndFlush(new HttpChunkedInput(new ChunkedStream(inputStream)), ctx.newProgressivePromise());
Теперь представьте inputStream блоков в его методе read() иногда, так как он используется для извлечения данных из сети.
Что такоерекомендуемый способ обработки этой ситуации, чтобы избежать влияния на потоки ввода-вывода?
Мой конвейер использует:
p.addLast(new ChunkedWriteHandler());