diff --git a/api/src/examples/java/org/reactivestreams/example/unicast/InfiniteIncrementNumberPublisher.java b/api/src/examples/java/org/reactivestreams/example/unicast/InfiniteIncrementNumberPublisher.java index 66b719ed..f32cfb65 100644 --- a/api/src/examples/java/org/reactivestreams/example/unicast/InfiniteIncrementNumberPublisher.java +++ b/api/src/examples/java/org/reactivestreams/example/unicast/InfiniteIncrementNumberPublisher.java @@ -1,6 +1,7 @@ package org.reactivestreams.example.unicast; import java.util.concurrent.atomic.AtomicLong; +import java.util.concurrent.atomic.AtomicInteger; import org.reactivestreams.Subscription; import org.reactivestreams.Subscriber; @@ -49,4 +50,4 @@ public void cancel() { s.onSubscribe(subscription); } -} \ No newline at end of file +}