testWriteScheduled() — netty Function Reference
Architecture documentation for the testWriteScheduled() function in EmbeddedChannelTest.java from the netty codebase.
Entity Profile
Dependency Diagram
graph TD 055e6bc5_1001_b2f1_1fb6_c2a75bd9a149["testWriteScheduled()"] 300cabef_b042_697f_5623_37ce249f504d["EmbeddedChannelTest"] 055e6bc5_1001_b2f1_1fb6_c2a75bd9a149 -->|defined in| 300cabef_b042_697f_5623_37ce249f504d style 055e6bc5_1001_b2f1_1fb6_c2a75bd9a149 fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Source Code
transport/src/test/java/io/netty/channel/embedded/EmbeddedChannelTest.java lines 405–427
@Test
public void testWriteScheduled() throws InterruptedException {
final int delay = 500;
EmbeddedChannel channel = new EmbeddedChannel(new ChannelOutboundHandlerAdapter() {
@Override
public void write(final ChannelHandlerContext ctx, final Object msg, final ChannelPromise promise)
throws Exception {
ctx.executor().schedule(new Runnable() {
@Override
public void run() {
ctx.writeAndFlush(msg, promise);
}
}, delay, TimeUnit.MILLISECONDS);
}
});
Object msg = new Object();
assertFalse(channel.writeOutbound(msg));
Thread.sleep(delay * 2);
assertTrue(channel.finish());
assertSame(msg, channel.readOutbound());
assertNull(channel.readOutbound());
}
Domain
Subdomains
Source
Frequently Asked Questions
What does testWriteScheduled() do?
testWriteScheduled() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/embedded/EmbeddedChannelTest.java.
Where is testWriteScheduled() defined?
testWriteScheduled() is defined in transport/src/test/java/io/netty/channel/embedded/EmbeddedChannelTest.java at line 405.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free