Home
last modified time | relevance | path

Searched defs:eventLoop (Results 1 – 20 of 20) sorted by relevance

/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/
DHttp1TunnelConnectionPool.java48 private final EventLoop eventLoop; field in Http1TunnelConnectionPool
59 … public Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext, in Http1TunnelConnectionPool()
67 … public Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext, in Http1TunnelConnectionPool()
77 Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext, in Http1TunnelConnectionPool()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DBuilders.kt44 val eventLoop: EventLoop? in runBlocking() constant
65 private val eventLoop: EventLoop? constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/
DBuilders.kt41 val eventLoop: EventLoop? in runBlocking() constant
98 private val eventLoop: EventLoop? constant
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyHandlerTestBase.java133 EventLoop eventLoop; field in NettyHandlerTestBase.FakeClockSupportedChanel
140 public EventLoop eventLoop() { in eventLoop() method in NettyHandlerTestBase.FakeClockSupportedChanel
171 EventLoop eventLoop, final Runnable command, long delay, TimeUnit timeUnit) { in FakeClockScheduledNettyFuture()
347 EventLoop eventLoop = mock(EventLoop.class); in newMockContext() local
DWriteQueueTest.java74 EventLoop eventLoop = Mockito.mock(EventLoop.class); in setUp() local
DNettyStreamTestBase.java76 protected EventLoop eventLoop; field in NettyStreamTestBase
DNettyServerTest.java90 private final NioEventLoopGroup eventLoop = new NioEventLoopGroup(1); field in NettyServerTest
545 verifyServerNotStart(ImmutableList.of(add1, add2, add3), eventLoop, in testBindPartialFailure() local
DNettyClientHandlerTest.java994 EventLoop eventLoop, in TransportStateImpl()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/
DDispatchedContinuation.kt302 val eventLoop = ThreadLocalEventLoop.eventLoop in executeUnconfined() constant
DDispatchedTask.kt184 val eventLoop = ThreadLocalEventLoop.eventLoop in resumeUnconfined() constant
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/nrs/
DHandlerSubscriberWhiteboxVerificationTest.java49 private DefaultEventLoopGroup eventLoop; field in HandlerSubscriberWhiteboxVerificationTest
DHandlerPublisherVerificationTest.java56 private DefaultEventLoopGroup eventLoop; field in HandlerPublisherVerificationTest
DChannelPublisherTest.java67 EventLoop eventLoop = group.next(); in start() local
DHandlerSubscriberTest.java54 private CustomEmbeddedEventLoop eventLoop; field in HandlerSubscriberTest
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerStream.java157 private final EventLoop eventLoop; field in NettyServerStream.TransportState
162 EventLoop eventLoop, in TransportState()
DNettyClientStream.java229 private final EventLoop eventLoop; field in NettyClientStream.TransportState
236 EventLoop eventLoop, in TransportState()
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/
DHealthCheckedChannelPoolTest.java54 private EventLoop eventLoop = Mockito.mock(EventLoop.class); field in HealthCheckedChannelPoolTest
DIdleConnectionCountingChannelPoolTest.java216 EventLoop eventLoop = this.eventLoopGroup.next(); in createSuccessfulAcquire() local
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/http2/
DHttpOrHttp2ChannelPool.java49 private final EventLoop eventLoop; field in HttpOrHttp2ChannelPool
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DEventLoop.common.kt128 internal val eventLoop: EventLoop constant