@Test
public void withMultipleClients() {

    new TestKit(actorSystem) {{
        final TestProbe sender = TestProbe.apply(actorSystem);
        final Connection connection = createConnectionWithClients(3);
        final Instant since = Instant.now().minusSeconds(333);
        final Instant until = Instant.now().plusSeconds(555);
        final Collection<RetrieveConnectionLogsResponse> responses = Arrays.asList(
                createRetrieveConnectionLogsResponse(connection.getId(), since, until),
                createRetrieveConnectionLogsResponse(connection.getId(), since, until),
                createRetrieveConnectionLogsResponse(connection.getId(), since, until)
        );
        final RetrieveConnectionLogsResponse expectedResponse = createExpectedResponse(responses);
        final ActorRef underTest = childActorOf(
                RetrieveConnectionLogsAggregatorActor.props(connection, sender.ref(), DITTO_HEADERS,
                        DEFAULT_TIMEOUT, LOGGER_CONFIG.maxLogSizeInBytes()));
        responses.forEach(response -> underTest.tell(response, getRef()));
        sender.expectMsg(expectedResponse);
    }};
}