Как протестировать обработчики блокировки с помощью EmbeddedChannel

Question

Я хочу протестировать некоторые обработчики с помощью EmbeddedChannel.

Один из обработчиков блокируется, и в контексте конвейера я использую метод addLast (группа EventExecutorGroup, ChannelHandler ... handlers), чтобы добавить его в конвейер. Пример:

pipeline.addLast(new NonBlockingHandler1(), new NonBlockingHandler2()); 
pipeline.addLast(eventGroup, new BlockingHandler()) 

Единственный способ добавить обработчиков к EmbeddedChannel через конструктор. Но здесь я не могу указать какой-либо EventExecutorGroup, который будет использоваться для одного обработчика блокировки. Как я могу проверить обработчик блокировки?

Answer 1

Вы можете использовать channel.pipeline().addLast(...)