Failing Rx-ness

SynchronisationService.java

        Observable.zip(
            Observable.from(spots),
            Observable.interval(SYNC_TICK, TimeUnit.MILLISECONDS),
            (obs, timer) -> obs)
            .subscribeOn(scheduler)
            .observeOn(scheduler)
            .unsubscribeOn(scheduler)
            .flatMap(spot -> syncTidePosition.get().buildObservable(spot))
            .subscribe(spotAndTideEvent -> new TideEventSubscriber(
                lunaEventService,
                synchronisationIntentProvider.get(),
                spotAndTideEvent.spot,
                String.format(
                    getString(string.tide_error_message),
                    spotAndTideEvent.spot.getTidePosition()
                ),
                errorHandlerService,
                localBroadcastManager)
            );