davidmoten / rxjava2-extras Goto Github PK

:app:transformClassesWithNewClassShrinkerForDebug
com/github/davidmoten/rx2/internal/flowable/buffertofile/MemoryMappedFile references unknown class: sun/misc/Unsafe
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$2$1 references unknown class: com/esotericsoftware/kryo/Kryo
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$5 references unknown class: com/esotericsoftware/kryo/io/Input
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$5 references unknown class: com/esotericsoftware/kryo/Kryo
com/github/davidmoten/rx2/internal/flowable/buffertofile/UnsafeAccess references unknown class: sun/misc/Unsafe
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder references unknown class: com/esotericsoftware/kryo/io/Input
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder references unknown class: com/esotericsoftware/kryo/Kryo
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$4 references unknown class: com/esotericsoftware/kryo/io/Input
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$2$1 references unknown class: com/esotericsoftware/kryo/io/Output
com/github/davidmoten/rx2/flowable/Serialized references unknown class: com/esotericsoftware/kryo/Kryo
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$3 references unknown class: com/esotericsoftware/kryo/io/Input
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$3.call:()Lcom/esotericsoftware/kryo/io/Input; references unknown class member: com/esotericsoftware/kryo/io/Input.<init>:(Ljava/io/InputStream;I)V
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$1 references unknown class: com/esotericsoftware/kryo/io/Output
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$2 references unknown class: com/esotericsoftware/kryo/io/Output
com/github/davidmoten/rx2/flowable/Serialized.kryo:()Lcom/github/davidmoten/rx2/flowable/Serialized$KryoBuilder; references unknown class member: com/esotericsoftware/kryo/Kryo.<init>:()V
com/github/davidmoten/rx2/internal/flowable/buffertofile/MemoryMappedFile references unknown class: sun/nio/ch/FileChannelImpl
com/github/davidmoten/rx2/flowable/Serialized$KryoBuilder$1.call:()Lcom/esotericsoftware/kryo/io/Output; references unknown class member: com/esotericsoftware/kryo/io/Output.<init>:(Ljava/io/OutputStream;I)V

// java String.split() works as expected
assertEquals(1, "Hello World\n".split("\n").length);

TestSubscriber<String> subscriber = Strings
  .from(new StringReader("Hello World\n"))
  .compose(Strings.split("\n"))
  .test();

subscriber.assertValueCount(1);  // Fails with a result of '2'
subscriber.assertValues("Hello World"); // Fails with a result of ['Hello World', '']

public class RetryLimiter<T> implements ObservableTransformer<T,T> {
    
    private final static String TAG = RetryLimiter.class.getSimpleName();
    
    private int errorCount = 0;
    private int maxErrorCount;
    
    private List<Class> countedExceptions;  // note errors not in this list (if defined) are not counted and will continue retries
    
    // constructor passes max tolerated consecutive errors (count is rezeroed upon a successful emission)
    public RetryLimiter( int maxErrors ) {
        if( maxErrors < 0 ) throw new IllegalArgumentException( "maxErrors cannot be < 0" );
        maxErrorCount = maxErrors;
    }
    
    // constructor that accepts a list of the types of exceptions to count (others are ignored)
    public RetryLimiter( int maxErrors, List<Class> exceptions ) {
        this( maxErrors );
        if( exceptions != null ) {
            for( Class c : exceptions ) {  // check that the supplied list contains only Throwable (sub)classes
                if( !Throwable.class.isAssignableFrom( c ) ) {  // is c a Throwable or subclass of Throwable?
                    throw new IllegalArgumentException( "List can only contain class Throwable or its subclasses" );
                }
            }
            countedExceptions = exceptions;
        } else {
            throw new NullPointerException( "If supplied, Exception Class list cannot be null" );
        }
    }
    
    @Override
    public ObservableSource<T> apply( Observable<T> upstream ) {
        return upstream
                .doOnError( err -> {
                    if( countedExceptions != null ) {
                        for( Class t : countedExceptions ) {
                            if( err.getClass().equals( t ) ) {
                                errorCount++;
                                break;        // don't count more than once
                            }
                        }
                    } else {  // null list of counted Exceptions
                        errorCount++;
                    }
                    if( DEBUG ) Log.d( TAG, "Consecutive error #" + errorCount + ": " + err.toString() );
                } )  
                .doOnNext( next -> errorCount = 0 )
                .retryUntil( () -> errorCount > maxErrorCount );
    }
}

testDoesNotTwoErrorsIfUpstreamDoesNotHonourCancellationImmediately(com.github.davidmoten.rx2.internal.flowable.FlowableCollectWhileTest)

  testDoesNotTwoErrorsIfUpstreamDoesNotHonourCancellationImmediately(com.github.davidmoten.rx2.internal.flowable.FlowableCollectWhileTest)
  testRebatchRequestsMinEqualsMaxDontConstrainFirstRequest(com.github.davidmoten.rx2.internal.flowable.FlowableMinRequestTest): expected:<[5, 5]> but was:<[5, 5, 5]>
  testConstrainedFirstRequest(com.github.davidmoten.rx2.internal.flowable.FlowableMinRequestTest): expected:<[2, 2, 2, 2, 2]> but was:<[2, 2, 2, 2, 2, 2]>
  testUnsubscribe(com.github.davidmoten.rx2.internal.flowable.FlowableMatchTest)