Tracked in JIRA by XXX
What have you tried to solve? Be short, but insightful.
Give enough context to reviewers and specify focus of the changes.
package com.pixite.pigment.testing | |
import android.app.Activity | |
import android.app.Application | |
import android.content.Context | |
import android.content.Intent | |
import android.os.Bundle | |
import androidx.fragment.app.Fragment | |
import androidx.fragment.app.FragmentActivity | |
import androidx.fragment.app.FragmentManager |
apply plugin: 'com.novoda.build-properties' | |
buildProperties { | |
local { | |
file rootProject.file('local.properties') | |
} | |
} | |
apply from: file('utilities.gradle') |
Tracked in JIRA by XXX
What have you tried to solve? Be short, but insightful.
Give enough context to reviewers and specify focus of the changes.
import android.app.Activity; | |
import android.app.Instrumentation; | |
import android.app.KeyguardManager; | |
import android.app.KeyguardManager.KeyguardLock; | |
import android.content.Context; | |
import android.content.pm.PackageManager; | |
import android.os.IBinder; | |
import android.os.PowerManager; | |
import android.os.PowerManager.WakeLock; | |
import android.support.test.InstrumentationRegistry; |
import java.util.concurrent.atomic.AtomicReference; | |
import rx.Observable; | |
import rx.functions.Action1; | |
import rx.functions.Func0; | |
class CachingObservableReplayer<T> implements Observable.Transformer<T, T> { | |
private final AtomicReference<Observable<T>> pendingObservable; |
/* | |
* Copyright (C) 2015 Jake Wharton | |
* | |
* 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 |
import rx.Observable; | |
import rx.functions.Action0; | |
import rx.functions.Func0; | |
import java.util.concurrent.atomic.AtomicReference; | |
class SubscribedObservableReplayer<T> implements Observable.Transformer<T, T> { | |
private final AtomicReference<Observable<T>> pendingObservable; |
import java.util.concurrent.atomic.AtomicReference; | |
import rx.Observable; | |
import rx.Subscriber; | |
import rx.functions.Action0; | |
import rx.functions.Func0; | |
/** | |
* This custom {@link Observable.Transformer} can be used to replay an in flight {@link Observable} | |
* source among all {@link Subscriber}s subscribed before its termination. | |
*/ |
#!/bin/sh | |
set -e | |
if [ -z "$1" ]; then | |
shot_path=$(date +%Y-%m-%d-%H-%M-%S).mp4 | |
else | |
shot_path="$*" | |
fi |
/** | |
* @param interval The base interval to start backing off from. The function is: attemptNum^2 * intervalTime | |
* @param units The units for interval | |
* @param retryAttempts The max number of attempts to retry this task or -1 to try MAX_INT times, | |
*/ | |
public static <T> Observable.Transformer<T, T> backoff(final long interval, final TimeUnit units, final int retryAttempts) { | |
return new Observable.Transformer<T, T>() { | |
@Override | |
public Observable<T> call(final Observable<T> observable) { | |
return observable.retryWhen( |