diff --git a/factcast-core/src/main/java/org/factcast/core/subscription/SpecBuilder.java b/factcast-core/src/main/java/org/factcast/core/subscription/SpecBuilder.java index e449df68d5..4010fc9182 100644 --- a/factcast-core/src/main/java/org/factcast/core/subscription/SpecBuilder.java +++ b/factcast-core/src/main/java/org/factcast/core/subscription/SpecBuilder.java @@ -27,6 +27,8 @@ public interface SpecBuilder { SubscriptionRequest from(@NonNull UUID id); + SubscriptionRequest fromNullable(UUID id); + SubscriptionRequest fromScratch(); SubscriptionRequest fromNowOn(); diff --git a/factcast-core/src/test/java/org/factcast/core/subscription/FluentSubscriptionRequestTest.java b/factcast-core/src/test/java/org/factcast/core/subscription/FluentSubscriptionRequestTest.java index 5abcaa95f4..64f7c56e20 100644 --- a/factcast-core/src/test/java/org/factcast/core/subscription/FluentSubscriptionRequestTest.java +++ b/factcast-core/src/test/java/org/factcast/core/subscription/FluentSubscriptionRequestTest.java @@ -40,6 +40,12 @@ void testFollowNull() { (FactSpec) null)); } + @Test + void testFollowNullable() { + SubscriptionRequest req = SubscriptionRequest.follow(FactSpec.ns("foo")).fromNullable(null); + assertFalse(req.startingAfter().isPresent()); + } + @Test void testCatchupNull() { Assertions.assertThrows(NullPointerException.class, () -> SubscriptionRequest.catchup(