test_class.declarator: ENTITY_ID = ThingId.generateRandom()
test_class.modifier: private static final
test_class.original_string: private static final ThingId ENTITY_ID = ThingId.generateRandom();
test_class.type: ThingId
test_class.var_name: ENTITY_ID
test_class.declarator: TIMEOUT = Duration.ofMillis(1337)
test_class.modifier: private static final
test_class.original_string: private static final Duration TIMEOUT = Duration.ofMillis(1337);
test_class.type: Duration
test_class.var_name: TIMEOUT
test_class.declarator: HEADER_TRANSLATOR = HeaderTranslator.empty()
test_class.modifier: private static final
test_class.original_string: private static final HeaderTranslator HEADER_TRANSLATOR = HeaderTranslator.empty();
test_class.type: HeaderTranslator
test_class.var_name: HEADER_TRANSLATOR
test_class.declarator: testName = new TestName()
test_class.modifier: @Rule
      public final
test_class.original_string: @Rule
      public final TestName testName = new TestName();
test_class.type: TestName
test_class.var_name: testName
test_class.declarator: correlationId
test_class.modifier: private
test_class.original_string: private String correlationId;
test_class.type: String
test_class.var_name: correlationId
test_class.declarator: dittoHeaders
test_class.modifier: private
test_class.original_string: private DittoHeaders dittoHeaders;
test_class.type: DittoHeaders
test_class.var_name: dittoHeaders
test_class.file: services/models/acks/src/test/java/org/eclipse/ditto/services/models/acks/AcknowledgementAggregatorTest.java
test_class.identifier: AcknowledgementAggregatorTest
test_case.body: @Test
      public void receivedAllRequestedAcknowledgements() {
          final AcknowledgementAggregator underTest =
                  AcknowledgementAggregator.getInstance(ENTITY_ID, correlationId, TIMEOUT, HEADER_TRANSLATOR);
          final List<Acknowledgement> acknowledgements = createAcknowledgements(3, HttpStatusCode.NO_CONTENT);
          acknowledgements.addAll(createAcknowledgements(2, HttpStatusCode.BAD_REQUEST));
          acknowledgements.forEach(
                  ack -> underTest.addAcknowledgementRequest(AcknowledgementRequest.of(ack.getLabel())));
          acknowledgements.forEach(underTest::addReceivedAcknowledgment);
  
          assertThat(underTest.receivedAllRequestedAcknowledgements()).isTrue();
      }
test_case.class_method_signature: AcknowledgementAggregatorTest.receivedAllRequestedAcknowledgements()
test_case.full_signature: @Test public void receivedAllRequestedAcknowledgements()
test_case.identifier: receivedAllRequestedAcknowledgements
test_case.invocations: getInstance createAcknowledgements addAll createAcknowledgements forEach addAcknowledgementRequest of getLabel forEach isTrue assertThat receivedAllRequestedAcknowledgements
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void receivedAllRequestedAcknowledgements()
focal_class.declarator: DEFAULT_INITIAL_CAPACITY = 4
focal_class.modifier: private static final
focal_class.original_string: private static final byte DEFAULT_INITIAL_CAPACITY = 4;
focal_class.type: byte
focal_class.var_name: DEFAULT_INITIAL_CAPACITY
focal_class.declarator: entityId
focal_class.modifier: private final
focal_class.original_string: private final EntityIdWithType entityId;
focal_class.type: EntityIdWithType
focal_class.var_name: entityId
focal_class.declarator: correlationId
focal_class.modifier: private final
focal_class.original_string: private final String correlationId;
focal_class.type: String
focal_class.var_name: correlationId
focal_class.declarator: headerTranslator
focal_class.modifier: private final
focal_class.original_string: private final HeaderTranslator headerTranslator;
focal_class.type: HeaderTranslator
focal_class.var_name: headerTranslator
focal_class.declarator: acknowledgementMap
focal_class.modifier: private final
focal_class.original_string: private final Map<AcknowledgementLabel, Acknowledgement> acknowledgementMap;
focal_class.type: Map<AcknowledgementLabel, Acknowledgement>
focal_class.var_name: acknowledgementMap
focal_class.declarator: timeout
focal_class.modifier: private final
focal_class.original_string: private final Duration timeout;
focal_class.type: Duration
focal_class.var_name: timeout
focal_class.declarator: expectedLabels
focal_class.modifier: private final
focal_class.original_string: private final Set<AcknowledgementLabel> expectedLabels;
focal_class.type: Set<AcknowledgementLabel>
focal_class.var_name: expectedLabels
focal_class.file: services/models/acks/src/main/java/org/eclipse/ditto/services/models/acks/AcknowledgementAggregator.java
focal_class.identifier: AcknowledgementAggregator
focal_class.class_method_signature: AcknowledgementAggregator.AcknowledgementAggregator(final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.full_signature: private  AcknowledgementAggregator(final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.identifier: AcknowledgementAggregator
focal_class.modifiers: private
focal_class.parameters: (final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.signature:  AcknowledgementAggregator(final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.class_method_signature: AcknowledgementAggregator.getInstance(final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.full_signature: public static AcknowledgementAggregator getInstance(final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: (final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.return: AcknowledgementAggregator
focal_class.signature: AcknowledgementAggregator getInstance(final EntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.class_method_signature: AcknowledgementAggregator.getInstance(final NamespacedEntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.full_signature: public static AcknowledgementAggregator getInstance(final NamespacedEntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: (final NamespacedEntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.return: AcknowledgementAggregator
focal_class.signature: AcknowledgementAggregator getInstance(final NamespacedEntityIdWithType entityId,
              final CharSequence correlationId,
              final Duration timeout,
              final HeaderTranslator headerTranslator)
focal_class.class_method_signature: AcknowledgementAggregator.getCorrelationId()
focal_class.full_signature: public String getCorrelationId()
focal_class.identifier: getCorrelationId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getCorrelationId()
focal_class.class_method_signature: AcknowledgementAggregator.addAcknowledgementRequest(final AcknowledgementRequest acknowledgementRequest)
focal_class.full_signature: public void addAcknowledgementRequest(final AcknowledgementRequest acknowledgementRequest)
focal_class.identifier: addAcknowledgementRequest
focal_class.modifiers: public
focal_class.parameters: (final AcknowledgementRequest acknowledgementRequest)
focal_class.return: void
focal_class.signature: void addAcknowledgementRequest(final AcknowledgementRequest acknowledgementRequest)
focal_class.class_method_signature: AcknowledgementAggregator.getTimeoutAcknowledgement(final AcknowledgementLabel acknowledgementLabel)
focal_class.full_signature: private Acknowledgement getTimeoutAcknowledgement(final AcknowledgementLabel acknowledgementLabel)
focal_class.identifier: getTimeoutAcknowledgement
focal_class.modifiers: private
focal_class.parameters: (final AcknowledgementLabel acknowledgementLabel)
focal_class.return: Acknowledgement
focal_class.signature: Acknowledgement getTimeoutAcknowledgement(final AcknowledgementLabel acknowledgementLabel)
focal_class.class_method_signature: AcknowledgementAggregator.addAcknowledgementRequests(final Collection<AcknowledgementRequest> acknowledgementRequests)
focal_class.full_signature: public void addAcknowledgementRequests(final Collection<AcknowledgementRequest> acknowledgementRequests)
focal_class.identifier: addAcknowledgementRequests
focal_class.modifiers: public
focal_class.parameters: (final Collection<AcknowledgementRequest> acknowledgementRequests)
focal_class.return: void
focal_class.signature: void addAcknowledgementRequests(final Collection<AcknowledgementRequest> acknowledgementRequests)
focal_class.class_method_signature: AcknowledgementAggregator.addReceivedAcknowledgment(final Acknowledgement acknowledgement)
focal_class.full_signature: public void addReceivedAcknowledgment(final Acknowledgement acknowledgement)
focal_class.identifier: addReceivedAcknowledgment
focal_class.modifiers: public
focal_class.parameters: (final Acknowledgement acknowledgement)
focal_class.return: void
focal_class.signature: void addReceivedAcknowledgment(final Acknowledgement acknowledgement)
focal_class.class_method_signature: AcknowledgementAggregator.isExpected(final Acknowledgement acknowledgement)
focal_class.full_signature: private boolean isExpected(final Acknowledgement acknowledgement)
focal_class.identifier: isExpected
focal_class.modifiers: private
focal_class.parameters: (final Acknowledgement acknowledgement)
focal_class.return: boolean
focal_class.signature: boolean isExpected(final Acknowledgement acknowledgement)
focal_class.class_method_signature: AcknowledgementAggregator.filterHeaders(final DittoHeaders dittoHeaders)
focal_class.full_signature: private DittoHeaders filterHeaders(final DittoHeaders dittoHeaders)
focal_class.identifier: filterHeaders
focal_class.modifiers: private
focal_class.parameters: (final DittoHeaders dittoHeaders)
focal_class.return: DittoHeaders
focal_class.signature: DittoHeaders filterHeaders(final DittoHeaders dittoHeaders)
focal_class.class_method_signature: AcknowledgementAggregator.receivedAllRequestedAcknowledgements()
focal_class.full_signature: public boolean receivedAllRequestedAcknowledgements()
focal_class.identifier: receivedAllRequestedAcknowledgements
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean receivedAllRequestedAcknowledgements()
focal_class.class_method_signature: AcknowledgementAggregator.isSuccessful()
focal_class.full_signature: public boolean isSuccessful()
focal_class.identifier: isSuccessful
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isSuccessful()
focal_class.class_method_signature: AcknowledgementAggregator.getAggregatedAcknowledgements(final DittoHeaders dittoHeaders)
focal_class.full_signature: public Acknowledgements getAggregatedAcknowledgements(final DittoHeaders dittoHeaders)
focal_class.identifier: getAggregatedAcknowledgements
focal_class.modifiers: public
focal_class.parameters: (final DittoHeaders dittoHeaders)
focal_class.return: Acknowledgements
focal_class.signature: Acknowledgements getAggregatedAcknowledgements(final DittoHeaders dittoHeaders)
focal_class.class_method_signature: AcknowledgementAggregator.validateCorrelationId(final DittoHeaders dittoHeaders)
focal_class.full_signature: private void validateCorrelationId(final DittoHeaders dittoHeaders)
focal_class.identifier: validateCorrelationId
focal_class.modifiers: private
focal_class.parameters: (final DittoHeaders dittoHeaders)
focal_class.return: void
focal_class.signature: void validateCorrelationId(final DittoHeaders dittoHeaders)
focal_method.body: public boolean receivedAllRequestedAcknowledgements() {
          return expectedLabels.isEmpty();
      }
focal_method.class_method_signature: AcknowledgementAggregator.receivedAllRequestedAcknowledgements()
focal_method.full_signature: public boolean receivedAllRequestedAcknowledgements()
focal_method.identifier: receivedAllRequestedAcknowledgements
focal_method.invocations: isEmpty
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: boolean
focal_method.signature: boolean receivedAllRequestedAcknowledgements()