@Test public void requestUnsubscribe() { final Connection connection = createConnection(); assertEquals( connection.getPendingAreaOfInterestRequests().size(), 0 ); final ChannelAddress address1 = new ChannelAddress( 1, 0 ); final ChannelAddress address2 = new ChannelAddress( 1, 1, 23 ); connection.requestUnsubscribe( address1 ); assertEquals( connection.getPendingAreaOfInterestRequests().size(), 1 ); connection.requestUnsubscribe( address2 ); assertEquals( connection.getPendingAreaOfInterestRequests().size(), 2 ); final AreaOfInterestRequest request1 = connection.getPendingAreaOfInterestRequests().get( 0 ); final AreaOfInterestRequest request2 = connection.getPendingAreaOfInterestRequests().get( 1 ); assertEquals( request1.getAddress(), address1 ); assertNull( request1.getFilter() ); assertEquals( request1.getType(), AreaOfInterestRequest.Type.REMOVE ); assertEquals( request2.getAddress(), address2 ); assertNull( request2.getFilter() ); assertEquals( request2.getType(), AreaOfInterestRequest.Type.REMOVE ); }
void requestUnsubscribe( @Nonnull final ChannelAddress address ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.REMOVE, null ); }
Connection { void requestUnsubscribe( @Nonnull final ChannelAddress address ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.REMOVE, null ); } }
Connection { void requestUnsubscribe( @Nonnull final ChannelAddress address ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.REMOVE, null ); } Connection( @Nonnull final Connector connector ); }
Connection { void requestUnsubscribe( @Nonnull final ChannelAddress address ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.REMOVE, null ); } Connection( @Nonnull final Connector connector );  }
Connection { void requestUnsubscribe( @Nonnull final ChannelAddress address ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.REMOVE, null ); } Connection( @Nonnull final Connector connector );   }