rxlint is a set of lint checks that check your RxJava code. There are currently two checks.
Checks if a RxJava subscriber is handling the
By default, RxJava will throw an
OnErrorNotImplemented exception wrapped in an
IllegalStateException for every error that is not handled for RxJava 1.x or will call the default uncaught exception handler directly if you are using RxJava 2.x before version 2.0.6.
When subscribing on a Scheduler, like
Schedulers.io() the error will be thrown on the scheduler thread and the stack trace will have no reference to the place where you subscribed.
TL;DR you should handle
Checks that your code keeps a reference to a
Subscription (rx 1.x) or
Disposable. Not keeping a reference means that you can't
dispose() at the appropriate times which might lead to memory leaks and crashes.
rxlint to your project is easy, just add the following dependency to your
Once added to your project an error will be shown like this:
If you are calling
subscribe() with a
Subscriber (rx 1.x) or
DisposableXXXSubscriber (rx 2.x) the subscriber is not checked for handling errors, and just plain
subscribe() isn't flagged either. In both cases I assume you know what you are doing :)
/* * Copyright 2016 Little Robots * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */