com.diffplug.common.rx

Class RxTracingPolicy.LogSubscriptionTrace

java.lang.Object

com.diffplug.common.rx.RxTracingPolicy.LogSubscriptionTrace

All Implemented Interfaces:

RxTracingPolicy

Enclosing interface:

RxTracingPolicy

public static class RxTracingPolicy.LogSubscriptionTrace
extends Object
implements RxTracingPolicy

An RxTracingPolicy which logs the stack trace of every subscription, so that it can decorate any exceptions with the stack trace at the time they were subscribed.

This logging is fairly expensive, so you might want to set the LogDisposableTrace#shouldLog field, which determines whether a subscription is logged or passed along untouched.

By default every Rx.onValue(java.util.function.Consumer<T>) listener will be logged, but nothing else.

To enable this tracing policy, do one of the following:

• Execute this at the very beginning of your application: `DurianPlugins.set(RxTracingPolicy.class, new LogDisposableTrace());`
• Set this system property: `durian.plugins.com.diffplug.common.rx.RxTracingPolicy=com.diffplug.common.rx.RxTracingPolicy$LogDisposableTrace`

See Also:

LogSubscriptionTrace source code, DurianPlugins

Nested Class Summary

Nested classes/interfaces inherited from interface com.diffplug.common.rx.RxTracingPolicy

RxTracingPolicy.LogSubscriptionTrace

Field Summary

Fields

Modifier and Type	Field and Description
static BiPredicate<Object,RxListener<?>>	shouldLog The BiPredicate which determines which subscriptions should be logged.

Fields inherited from interface com.diffplug.common.rx.RxTracingPolicy

NONE

Constructor Summary

Constructors

Constructor and Description
LogSubscriptionTrace()

Method Summary

Modifier and Type	Method and Description
<T> RxListener<T>	hook(Object observable, RxListener<T> listener) Given an observable, and an Rx which is about to be subscribed to this observable, return a (possibly instrumented) `Rx`.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

shouldLog

public static BiPredicate<Object,RxListener<?>> shouldLog

The BiPredicate which determines which subscriptions should be logged. By default, any Rx which is logging will be logged.

Constructor Detail

LogSubscriptionTrace

public LogSubscriptionTrace()

Method Detail

hook

public <T> RxListener<T> hook(Object observable,
                              RxListener<T> listener)

Description copied from interface: RxTracingPolicy

Given an observable, and an Rx which is about to be subscribed to this observable, return a (possibly instrumented) `Rx`.

Specified by:

hook in interface RxTracingPolicy

Parameters:

observable - The IObservable, Observable, or ListenableFuture which is about to be subscribed to.

listener - The Rx which is about to be subscribed.

Returns:

An Rx which may (or may not) be instrumented. To ensure that the program's behavior is not changed, implementors should ensure that all method calls are delegated unchanged to the original listener eventually.