From 5d46855fe03bcc3abde740bf5c262470f1c4fd1d Mon Sep 17 00:00:00 2001 From: zhuchenwang Date: Fri, 7 Nov 2014 17:05:48 -0800 Subject: [PATCH] Fixed the compilation error in unicast example --- .../example/unicast/InfiniteIncrementNumberPublisher.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 +}