this.setter = setter;
this.channel = channel;
}
public void handleEvent(final StreamSourceChannel channel) {
ChannelListener<? super StreamSourceChannel> channelListener = setter.get();
<BUG>if (channelListener != null) {
ChannelListeners.invokeChannelListener(this.channel, channelListener);</BUG>
} else {
UndertowLogger.REQUEST_LOGGER.debugf("suspending reads on %s to prevent listener runaway", channel);
channel.suspendReads();

this.setter = setter;
this.channel = channel;
}
public void handleEvent(final StreamSourceChannel channel) {
ChannelListener<? super StreamSourceChannel> channelListener = setter.get();
if(channelListener != null) {
ChannelListeners.invokeChannelListener(this.channel, channelListener);
} else {
UndertowLogger.REQUEST_LOGGER.debugf("suspending reads on %s to prevent listener runaway", channel);
channel.suspendReads();
