@Test public void pendingAreaOfInterestRequestQueries_currentPending() { final Connection connection = createConnection(); final ChannelAddress address1 = new ChannelAddress( 1, 0, 1 ); final ChannelAddress address2 = new ChannelAddress( 1, 0, 2 ); final ChannelAddress address3 = new ChannelAddress( 1, 0, 3 ); final Object filter1 = null; final Object filter2 = null; final Object filter3 = null; assertRequestPendingState( connection, address1, filter1, false, false, false, -1, -1, -1 ); assertRequestPendingState( connection, address2, filter2, false, false, false, -1, -1, -1 ); assertRequestPendingState( connection, address3, filter3, false, false, false, -1, -1, -1 ); connection.injectCurrentAreaOfInterestRequest( new AreaOfInterestRequest( address1, AreaOfInterestRequest.Type.ADD, filter1 ) ); assertRequestPendingState( connection, address1, filter1, true, false, false, 0, -1, -1 ); assertRequestPendingState( connection, address2, filter2, false, false, false, -1, -1, -1 ); assertRequestPendingState( connection, address3, filter3, false, false, false, -1, -1, -1 ); connection.injectCurrentAreaOfInterestRequest( new AreaOfInterestRequest( address2, AreaOfInterestRequest.Type.ADD, filter2 ) ); assertRequestPendingState( connection, address1, filter1, true, false, false, 0, -1, -1 ); assertRequestPendingState( connection, address2, filter2, true, false, false, 0, -1, -1 ); assertRequestPendingState( connection, address3, filter3, false, false, false, -1, -1, -1 ); }
void injectCurrentAreaOfInterestRequest( @Nonnull final AreaOfInterestRequest request ) { _currentAreaOfInterestRequests.add( request ); }
Connection { void injectCurrentAreaOfInterestRequest( @Nonnull final AreaOfInterestRequest request ) { _currentAreaOfInterestRequests.add( request ); } }
Connection { void injectCurrentAreaOfInterestRequest( @Nonnull final AreaOfInterestRequest request ) { _currentAreaOfInterestRequests.add( request ); } Connection( @Nonnull final Connector connector ); }
Connection { void injectCurrentAreaOfInterestRequest( @Nonnull final AreaOfInterestRequest request ) { _currentAreaOfInterestRequests.add( request ); } Connection( @Nonnull final Connector connector );  }
Connection { void injectCurrentAreaOfInterestRequest( @Nonnull final AreaOfInterestRequest request ) { _currentAreaOfInterestRequests.add( request ); } Connection( @Nonnull final Connector connector );   }