sebaslogen

Verifying that +sebas is my Bitcoin username. You can send me #bitcoin here: https://onename.io/sebas

sebaslogen

Verifying that +neoranga55 is my Bitcoin username. You can send me #bitcoin here: https://onename.io/neoranga55

sebaslogen

Verifying that +sebas is my blockchain ID. https://onename.com/sebas

sebaslogen

Note that the file lives in the package as Picasso (src/androidTest/java/com/squareup/picasso). Otherwise we don't have access to targetToAction

package com.squareup.picasso;

import android.app.Activity;
import android.os.Handler;
import android.support.test.espresso.IdlingResource;
import android.support.test.runner.lifecycle.ActivityLifecycleCallback;
import android.support.test.runner.lifecycle.Stage;

sebaslogen

BehaviorRelay<Integer> brelay = BehaviorRelay.create();
Observable<Integer> relayObservable = brelay
        .doOnSubscribe(() -> {
            Log.i("RxExperiments", "BehaviorRelayProblem->doOnSubscribe");
        }).doOnUnsubscribe(() -> {
            Log.i("RxExperiments", "BehaviorRelayProblem->doOnUnsubscribe");
        });

Log.i("RxExperiments", "BehaviorRelayProblem->observer-1 subscribes");
Subscription subscription1 = relayObservable.subscribe(i -> {

sebaslogen

BehaviorRelay<Integer> behaviorRelay = BehaviorRelay.create();
Observable<Integer> relayObservable = behaviorRelay
        .doOnSubscribe(() -> {
            Log.i("RxExperiments", "share->doOnSubscribe");
        }).doOnUnsubscribe(() -> {
            Log.i("RxExperiments", "share->doOnUnsubscribe");
        })
        .share();

Log.i("RxExperiments", "share->observer-1 subscribes");

sebaslogen

PublishRelay<Integer> publishRelay = PublishRelay.create();
Observable<Integer> relayObservable = publishRelay
        .doOnSubscribe(() -> {
            Log.i("RxExperiments", "ReplayingShare->doOnSubscribe");
            // Register to event here...
        }).doOnUnsubscribe(() -> {
            Log.i("RxExperiments", "ReplayingShare->doOnUnsubscribe");
            // Un-register from event here...
        })
        .compose(ReplayingShare.instance());

sebaslogen

<component name="InspectionProjectProfileManager">
  <profile version="1.0">
    <option name="myName" value="Project Default" />
    <inspection_tool class="AndroidLintDrawAllocation" enabled="true" level="ERROR" enabled_by_default="true" />
    <inspection_tool class="SSBasedInspection" enabled="true" level="ERROR" enabled_by_default="true">
      <replaceConfiguration name="Escape apostrophes in Android string XMLs" text="&lt;string $attributes$&gt;$text$&lt;/string&gt;" recursive="false" caseInsensitive="true" type="XML" reformatAccordingToStyle="true" shortenFQN="true" useStaticImport="true" replacement="&lt;string $attributes$&gt;$fixedText$&lt;/string&gt;">
        <constraint name="attributes" minCount="0" maxCount="2147483647" within="" contains="" />
        <constraint name="text" regexp=".*[^\\]'.*" maxCount="2147483647" within="" contains="" />
        <variableDefinition name="fixedText" script="&quot;text.getValue().replaceAll( &quot;\\\\'|\'&quot;, &quot;\\\\'&quot; )&quot;" />
      </replace

sebaslogen

import android.arch.lifecycle.Lifecycle
import android.arch.lifecycle.LifecycleObserver
import android.arch.lifecycle.LifecycleOwner
import android.arch.lifecycle.OnLifecycleEvent
import com.jakewharton.rxrelay.BehaviorRelay
import rx.Observable
import rx.android.schedulers.AndroidSchedulers
import rx.functions.Action1
import rx.subscriptions.CompositeSubscription

sebaslogen

class MainApplication : Application() {

    private val createdActivities = mutableListOf<WeakReference<Activity>>()

    override fun onCreate() {
        super.onCreate()
        registerActivityLifecycleCallbacks(activityLifecycleCallbacks())
    }

    fun closeAllActivities() {