@Test public void completeAreaOfInterestRequest() { final Connector connector = createConnector(); final Connection connection = newConnection( connector ); connection.injectCurrentAreaOfInterestRequest( new AreaOfInterestRequest( new ChannelAddress( 1, 0 ), AreaOfInterestRequest.Type.ADD, null ) ); assertFalse( connection.getCurrentAreaOfInterestRequests().isEmpty() ); connector.completeAreaOfInterestRequest(); assertTrue( connection.getCurrentAreaOfInterestRequests().isEmpty() ); }
void completeAreaOfInterestRequest() { if ( null != _connection ) { _connection.completeAreaOfInterestRequest(); } triggerMessageScheduler(); }
Connector extends ReplicantService { void completeAreaOfInterestRequest() { if ( null != _connection ) { _connection.completeAreaOfInterestRequest(); } triggerMessageScheduler(); } }
Connector extends ReplicantService { void completeAreaOfInterestRequest() { if ( null != _connection ) { _connection.completeAreaOfInterestRequest(); } triggerMessageScheduler(); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); }
Connector extends ReplicantService { void completeAreaOfInterestRequest() { if ( null != _connection ) { _connection.completeAreaOfInterestRequest(); } triggerMessageScheduler(); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString(); }
Connector extends ReplicantService { void completeAreaOfInterestRequest() { if ( null != _connection ) { _connection.completeAreaOfInterestRequest(); } triggerMessageScheduler(); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString();  }