@Test public void requestSubscriptionUpdate() { final Connection connection = createConnection(); assertEquals( connection.getPendingAreaOfInterestRequests().size(), 0 ); final ChannelAddress address1 = new ChannelAddress( 1, 0 ); final ChannelAddress address2 = new ChannelAddress( 1, 1, 23 ); final String filter1 = ValueUtil.randomString(); final String filter2 = ValueUtil.randomString(); connection.requestSubscriptionUpdate( address1, filter1 ); assertEquals( connection.getPendingAreaOfInterestRequests().size(), 1 ); connection.requestSubscriptionUpdate( address2, filter2 ); assertEquals( connection.getPendingAreaOfInterestRequests().size(), 2 ); final AreaOfInterestRequest request1 = connection.getPendingAreaOfInterestRequests().get( 0 ); final AreaOfInterestRequest request2 = connection.getPendingAreaOfInterestRequests().get( 1 ); assertEquals( request1.getAddress(), address1 ); assertEquals( request1.getFilter(), filter1 ); assertEquals( request1.getType(), AreaOfInterestRequest.Type.UPDATE ); assertEquals( request2.getAddress(), address2 ); assertEquals( request2.getFilter(), filter2 ); assertEquals( request2.getType(), AreaOfInterestRequest.Type.UPDATE ); }
void requestSubscriptionUpdate( @Nonnull final ChannelAddress address, @Nullable final Object filter ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.UPDATE, filter ); }
Connection { void requestSubscriptionUpdate( @Nonnull final ChannelAddress address, @Nullable final Object filter ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.UPDATE, filter ); } }
Connection { void requestSubscriptionUpdate( @Nonnull final ChannelAddress address, @Nullable final Object filter ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.UPDATE, filter ); } Connection( @Nonnull final Connector connector ); }
Connection { void requestSubscriptionUpdate( @Nonnull final ChannelAddress address, @Nullable final Object filter ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.UPDATE, filter ); } Connection( @Nonnull final Connector connector );  }
Connection { void requestSubscriptionUpdate( @Nonnull final ChannelAddress address, @Nullable final Object filter ) { enqueueAreaOfInterestRequest( address, AreaOfInterestRequest.Type.UPDATE, filter ); } Connection( @Nonnull final Connector connector );   }