// Path: src/main/java/org/reactivejournal/impl/rxjava/RxJavaPlayer.java
// public class RxJavaPlayer<T> {
//     private ReactivePlayer reactivePlayer;
// 
//     public RxJavaPlayer(ReactiveJournal reactiveJournal){
//         reactivePlayer = reactiveJournal.createReactivePlayer();
//     }
// 
//     public Flowable<T> play(PlayOptions options){
//         return Flowable.fromPublisher(reactivePlayer.play(options));
//     }
// }


import io.reactivex.BackpressureStrategy;
import io.reactivex.Flowable;
import org.junit.Assert;
import org.junit.Test;
import org.reactivejournal.impl.rxjava.RxJavaPlayer;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicInteger;
package org.reactivejournal.impl;




/**
 * Created by daniel on 17/05/17.
 */
public class ReactiveFromUntilSeqNoTest {
    @Test
    public void fromUntilTest() throws IOException {
// Path: src/main/java/org/reactivejournal/impl/rxjava/RxJavaPlayer.java
// public class RxJavaPlayer<T> {
//     private ReactivePlayer reactivePlayer;
// 
//     public RxJavaPlayer(ReactiveJournal reactiveJournal){
//         reactivePlayer = reactiveJournal.createReactivePlayer();
//     }
// 
//     public Flowable<T> play(PlayOptions options){
//         return Flowable.fromPublisher(reactivePlayer.play(options));
//     }
// }


// Path: src/test/java/org/reactivejournal/impl/ReactiveFromUntilSeqNoTest.java
import io.reactivex.BackpressureStrategy;
import io.reactivex.Flowable;
import org.junit.Assert;
import org.junit.Test;
import org.reactivejournal.impl.rxjava.RxJavaPlayer;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicInteger;

package org.reactivejournal.impl;




/**
 * Created by daniel on 17/05/17.
 */
public class ReactiveFromUntilSeqNoTest {
    @Test
    public void fromUntilTest() throws IOException {
        Flowable<String> errorFlowable = Flowable.create(