Quite right sorry. I'll fix. I was interested to see if any other operators
were affected by use of composite  subscription add method and had been
chucking in in other methods like delay
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>
> .
>