HomeSort by relevance Sort by last modified time
    Searched refs:EventLoop (Results 1 - 11 of 11) sorted by null

  /device/google/cuttlefish_common/guest/commands/vsoc_input_service/
vsoc_input_service.cpp 40 void EventLoop(std::shared_ptr<VirtualDeviceBase> device,
89 EventLoop(
96 EventLoop(virtual_keyboard_, [](InputEvent* event_buffer, int max_events) {
102 EventLoop(virtual_power_button_,
  /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
NettyHandlerTestBase.java 48 import io.netty.channel.EventLoop;
128 EventLoop eventLoop;
135 public EventLoop eventLoop() {
136 if (eventLoop == null) {
139 return eventLoop;
143 EventLoop realEventLoop = super.eventLoop();
147 eventLoop = mock(EventLoop.class, delegatesTo(realEventLoop))
    [all...]
WriteQueueTest.java 32 import io.netty.channel.EventLoop;
72 EventLoop eventLoop = Mockito.mock(EventLoop.class);
80 }).when(eventLoop).execute(any(Runnable.class));
81 when(eventLoop.inEventLoop()).thenReturn(true);
82 when(channel.eventLoop()).thenReturn(eventLoop);
NettyStreamTestBase.java 41 import io.netty.channel.EventLoop;
71 protected EventLoop eventLoop;
93 when(channel.eventLoop()).thenReturn(eventLoop);
102 when(eventLoop.inEventLoop()).thenReturn(true);
112 }).when(eventLoop).execute(any(Runnable.class));
NettyClientHandlerTest.java 75 import io.netty.channel.EventLoop;
171 channel().eventLoop(),
515 channel().eventLoop(),
524 channel().eventLoop(),
760 EventLoop eventLoop,
763 super(handler, eventLoop, maxMessageSize, StatsTraceContext.NOOP, transportTracer);
  /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
NettyServerStream.java 33 import io.netty.channel.EventLoop;
93 if (channel.eventLoop().inEventLoop()) {
97 channel.eventLoop().execute(new Runnable() {
159 private final EventLoop eventLoop;
163 EventLoop eventLoop,
171 this.eventLoop = eventLoop;
176 if (eventLoop.inEventLoop())
    [all...]
NettyClientStream.java 41 import io.netty.channel.EventLoop;
190 if (channel.eventLoop().inEventLoop()) {
194 channel.eventLoop().execute(new Runnable() {
213 private final EventLoop eventLoop;
219 EventLoop eventLoop,
225 this.eventLoop = checkNotNull(eventLoop, "eventLoop");
    [all...]
NettyClientTransport.java 48 import io.netty.channel.EventLoop;
161 channel.eventLoop(),
185 EventLoop eventLoop = group.next();
188 new ClientKeepAlivePinger(this), eventLoop, keepAliveTimeNanos, keepAliveTimeoutNanos,
207 b.group(eventLoop);
326 if (channel.eventLoop().inEventLoop()) {
332 channel.eventLoop().submit(
352 assert ch.eventLoop().inEventLoop();
  /external/python/cpython3/Lib/test/test_asyncio/
test_selector_events.py 120 class EventLoop(BaseSelectorEventLoop):
126 self.loop = EventLoop(self.selector)
    [all...]
test_base_events.py 797 class EventLoop(base_events.BaseEventLoop):
801 loop = EventLoop()
    [all...]
  /external/kotlinc/lib/
kotlin-main-kts.jar 

Completed in 1649 milliseconds