eventbus: use method references.
This commit is contained in:
@@ -53,10 +53,7 @@ public class EventBus implements EventBusInterface
|
|||||||
Disposable disposable = getSubject(eventClass)
|
Disposable disposable = getSubject(eventClass)
|
||||||
.filter(Objects::nonNull) // Filter out null objects, better safe than sorry
|
.filter(Objects::nonNull) // Filter out null objects, better safe than sorry
|
||||||
.cast(eventClass) // Cast it for easier usage
|
.cast(eventClass) // Cast it for easier usage
|
||||||
.subscribe(action, error ->
|
.subscribe(action, Sentry::capture);
|
||||||
{
|
|
||||||
Sentry.capture(error);
|
|
||||||
});
|
|
||||||
|
|
||||||
getCompositeDisposable(lifecycle).add(disposable);
|
getCompositeDisposable(lifecycle).add(disposable);
|
||||||
subscriptionList.put(lifecycle, eventClass);
|
subscriptionList.put(lifecycle, eventClass);
|
||||||
@@ -75,10 +72,7 @@ public class EventBus implements EventBusInterface
|
|||||||
.cast(eventClass) // Cast it for easier usage
|
.cast(eventClass) // Cast it for easier usage
|
||||||
.take(takeUntil)
|
.take(takeUntil)
|
||||||
.doFinally(() -> unregister(lifecycle))
|
.doFinally(() -> unregister(lifecycle))
|
||||||
.subscribe(action, error ->
|
.subscribe(action, Sentry::capture);
|
||||||
{
|
|
||||||
Sentry.capture(error);
|
|
||||||
});
|
|
||||||
|
|
||||||
getCompositeDisposable(lifecycle).add(disposable);
|
getCompositeDisposable(lifecycle).add(disposable);
|
||||||
subscriptionList.put(lifecycle, eventClass);
|
subscriptionList.put(lifecycle, eventClass);
|
||||||
|
|||||||
Reference in New Issue
Block a user