events() — netty Function Reference

Architecture documentation for the events() function in LocalTransportThreadModelTest3.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ events() — netty Function Reference

Dependency Diagram

graph TD
  3040527d_343e_e75c_3640_cf84c1de7f83["events()"]
  f86ec9f6_ad3f_1246_2bcb_3e0c74480849["LocalTransportThreadModelTest3"]
  3040527d_343e_e75c_3640_cf84c1de7f83 -->|defined in| f86ec9f6_ad3f_1246_2bcb_3e0c74480849
  364f868b_2802_fe3b_5533_83572757fe40["testConcurrentAddRemove()"]
  364f868b_2802_fe3b_5533_83572757fe40 -->|calls| 3040527d_343e_e75c_3640_cf84c1de7f83
  style 3040527d_343e_e75c_3640_cf84c1de7f83 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest3.java lines 245–262

    private static LinkedList<EventType> events(boolean inbound, int size) {
        EventType[] events;
        if (inbound) {
            events = new EventType[] {
                    EventType.USER_EVENT, EventType.MESSAGE_RECEIVED, EventType.MESSAGE_RECEIVED_LAST,
                    EventType.EXCEPTION_CAUGHT};
        } else {
            events = new EventType[] {
                    EventType.READ, EventType.WRITE, EventType.EXCEPTION_CAUGHT };
        }

        Random random = new Random();
        LinkedList<EventType> expectedEvents = new LinkedList<EventType>();
        for (int i = 0; i < size; i++) {
            expectedEvents.add(events[random.nextInt(events.length)]);
        }
        return expectedEvents;
    }