io.servicetalk.transport.netty.internal

Interface EventLoopAwareNettyIoExecutor

All Superinterfaces:

AsyncCloseable, IoExecutor, ListenableAsyncCloseable, NettyIoExecutor

public interface EventLoopAwareNettyIoExecutor
extends NettyIoExecutor

A special NettyIoExecutor that exposes the underlying netty EventLoopGroup.

Method Summary

Modifier and Type	Method and Description
io.netty.channel.EventLoopGroup	eventLoopGroup() Returns the underlying EventLoopGroup.
boolean	isCurrentThreadEventLoop() Checks if the calling thread is an I/O thread manager by this NettyIoExecutor.
EventLoopAwareNettyIoExecutor	next() Returns a EventLoopAwareNettyIoExecutor that is tied to a single EventLoop and not a EventLoopGroup.

Methods inherited from interface io.servicetalk.transport.netty.internal.NettyIoExecutor

asExecutor

Methods inherited from interface io.servicetalk.transport.api.IoExecutor

isFileDescriptorSocketAddressSupported, isUnixDomainSocketSupported

Methods inherited from interface io.servicetalk.concurrent.api.ListenableAsyncCloseable

onClose

Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable

closeAsync, closeAsyncGracefully

Method Detail

isCurrentThreadEventLoop

boolean isCurrentThreadEventLoop()

Checks if the calling thread is an I/O thread manager by this NettyIoExecutor.

Returns:

true if the calling thread is an I/O thread manager by this NettyIoExecutor.

eventLoopGroup

io.netty.channel.EventLoopGroup eventLoopGroup()

Returns the underlying EventLoopGroup.

Returns:

EventLoopGroup used by this EventLoopAwareNettyIoExecutor.

next

EventLoopAwareNettyIoExecutor next()

Returns a EventLoopAwareNettyIoExecutor that is tied to a single EventLoop and not a EventLoopGroup.

Returns:

EventLoopAwareNettyIoExecutor that is tied to a single EventLoop and not a EventLoopGroup.