public StreamDestinationFilterRuleDTO deleteFromStream(String streamId, String id) {
        final var dto = utils.getById(id)
                .orElseThrow(() -> new IllegalArgumentException(f("Couldn't find document with ID <%s> for deletion", id)));

        if (collection.deleteOne(and(eq(FIELD_STREAM_ID, streamId), idEq(id))).getDeletedCount() > 0) {
            clusterEventBus.post(StreamDestinationFilterDeletedEvent.of(id));
        }

        return dto;
    }
@Test
    @MongoDBFixtures("StreamDestinationFilterServiceTest-2024-07-01-1.json")
    void deleteFromStream() {
        final var optionalDto = service.findByIdForStream("54e3deadbeefdeadbeef1000", "54e3deadbeefdeadbeef0000");

        assertThat(optionalDto).isPresent();

        final var deletedDto = service.deleteFromStream("54e3deadbeefdeadbeef1000", "54e3deadbeefdeadbeef0000");

        assertThat(deletedDto.id()).isEqualTo("54e3deadbeefdeadbeef0000");

        assertThat(service.findByIdForStream("54e3deadbeefdeadbeef1000", "54e3deadbeefdeadbeef0000")).isNotPresent();
    }