Committed the test fix and the change to the original version to use per
observer sub and attempts
Dave
On 17 Feb 2014 19:16, "akarnokd" <notifications@github.com> wrote:

> In rxjava-core/src/test/java/rx/operators/OperationRetryTest.java:
>
> > +        final AtomicInteger subsCount = new AtomicInteger(0);
> > +        OnSubscribeFunc<String> onSubscribe = new OnSubscribeFunc<String>() {
> > +            @Override
> > +            public Subscription onSubscribe(Observer<? super String> observer) {
> > +                subsCount.incrementAndGet();
> > +                return new Subscription() {
> > +
> > +                    @Override
> > +                    public void unsubscribe() {
> > +                        subsCount.decrementAndGet();
> > +                    }
> > +                };
> > +            }
> > +        };
> > +        Observable<String> stream = Observable.create(onSubscribe);
> > +        Observable<String> streamWithRetry = stream.delay(1, TimeUnit.SECONDS);
>
> This doesn't test the retry() operator at all.
>
> --
> Reply to this email directly or view it on GitHub<https://github.com/Netflix/RxJava/pull/882/files#r9784402>
> .
>