netty Architecture Docs
Home / Function/ runBlockingOn() — netty Function Reference

runBlockingOn() — netty Function Reference

Architecture documentation for the runBlockingOn() function in AbstractSingleThreadEventLoopTest.java from the netty codebase.

Function java Buffer Search called by 3

Entity Profile

Dependency Diagram

graph TD
  d4cc6fcd_803a_7c6c_adf8_d25d73af7b63["runBlockingOn()"]
  eb487d77_b896_e5c3_20f1_2b7144dc7cf5["AbstractSingleThreadEventLoopTest"]
  d4cc6fcd_803a_7c6c_adf8_d25d73af7b63 -->|defined in| eb487d77_b896_e5c3_20f1_2b7144dc7cf5
  85bd87ad_e38f_a747_1986_6bbe9126a367["testChannelsIteratorEmpty()"]
  85bd87ad_e38f_a747_1986_6bbe9126a367 -->|calls| d4cc6fcd_803a_7c6c_adf8_d25d73af7b63
  b755284f_722b_7273_735c_350c2bc74ed2["testChannelsIterator()"]
  b755284f_722b_7273_735c_350c2bc74ed2 -->|calls| d4cc6fcd_803a_7c6c_adf8_d25d73af7b63
  c048b53a_33d7_8392_8dee_df47ef4ded8d["testChannelsIteratorRemoveThrows()"]
  c048b53a_33d7_8392_8dee_df47ef4ded8d -->|calls| d4cc6fcd_803a_7c6c_adf8_d25d73af7b63
  style d4cc6fcd_803a_7c6c_adf8_d25d73af7b63 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/AbstractSingleThreadEventLoopTest.java lines 405–430

    private static void runBlockingOn(EventLoop eventLoop, final Runnable action) {
        final Promise<Void> promise = eventLoop.newPromise();
            eventLoop.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        action.run();
                        promise.setSuccess(null);
                    } catch (Throwable t) {
                        promise.tryFailure(t);
                    }
                }
            });
        try {
            promise.await();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        Throwable cause = promise.cause();
        if (cause != null) {
            if (cause instanceof RuntimeException) {
                throw (RuntimeException) cause;
            }
            throw new RuntimeException(cause);
        }
    }

Domain

Subdomains

Defined In

Called By

Source

Frequently Asked Questions

What does runBlockingOn() do?
runBlockingOn() is a function in the netty codebase, defined in testsuite/src/main/java/io/netty/testsuite/transport/AbstractSingleThreadEventLoopTest.java.
Where is runBlockingOn() defined?
runBlockingOn() is defined in testsuite/src/main/java/io/netty/testsuite/transport/AbstractSingleThreadEventLoopTest.java at line 405.
What calls runBlockingOn()?
runBlockingOn() is called by 3 function(s): testChannelsIterator, testChannelsIteratorEmpty, testChannelsIteratorRemoveThrows.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free