execute the wrapped Runnable

This commit is contained in:
norman 2012-03-07 14:15:42 +01:00
parent 6375b84c9d
commit 62028f0042

View File

@ -30,7 +30,7 @@ public abstract class AbstractSctpChannelSink extends AbstractChannelSink {
if (ch instanceof SctpChannelImpl) { if (ch instanceof SctpChannelImpl) {
SctpChannelImpl channel = (SctpChannelImpl) ch; SctpChannelImpl channel = (SctpChannelImpl) ch;
ChannelRunnableWrapper wrapper = new ChannelRunnableWrapper(channel, task); ChannelRunnableWrapper wrapper = new ChannelRunnableWrapper(channel, task);
channel.worker.executeInIoThread(task); channel.worker.executeInIoThread(wrapper);
return wrapper; return wrapper;
} else { } else {