static MongoSubscription subscription()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java [47:58]

• 12 lines of code
• 3 McCabe index (conditional complexity)

    static MongoSubscription subscription(
            MessageReceiver receiver, Seek seek, Consumer<Received> consumer
    ) {
        switch (seek) {
            case latest:
                return new MongoSubscription(receiver, LATEST_INDEX, consumer);
            case earliest:
                return new MongoSubscription(receiver, EARLIEST_INDEX, consumer);
            default:
                throw new AssertionError(seek);
        }
    }