// Path: goro/src/test/java/com/stanfy/enroscar/goro/TestingQueues.java
// public class TestingQueues implements Queues {
// 
//   /** Scheduled tasks. */
//   private final ArrayList<Runnable> tasks = new ArrayList<>();
// 
//   /** Delegate executor. */
//   private Executor delegateExecutor = new Executor() {
//     @Override
//     public void execute(@SuppressWarnings("NullableProblems") final Runnable command) {
//       tasks.add(command);
//     }
//   };
// 
//   /** Last queue name. */
//   private String lastQueueName;
// 
//   @Override
//   public void setDelegateExecutor(final Executor delegate) {
//     delegateExecutor = delegate;
//   }
// 
//   @Override
//   public Executor getExecutor(final String queueName) {
//     lastQueueName = queueName;
//     return new TaskQueueExecutor(delegateExecutor);
//   }
// 
//   @Override
//   public void clear(final String queueName) {
//     lastQueueName = queueName;
//     tasks.clear();
//   }
// 
//   public String getLastQueueName() {
//     return lastQueueName;
//   }
// 
//   public void executeAll() {
//     for (Runnable command : tasks) {
//       command.run();
//     }
//     tasks.clear();
//   }
// 
// }
// 
// Path: goro/src/test/java/com/stanfy/enroscar/goro/GoroImplTest.java
// public static GoroImpl createGoroWith(TestingQueues queues) {
//   return new GoroImpl(queues);
// }


import com.stanfy.enroscar.goro.BuildConfig;
import com.stanfy.enroscar.goro.TestingQueues;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.robolectric.RobolectricTestRunner;
import org.robolectric.annotation.Config;
import rx.Observable;
import rx.Scheduler;
import rx.Subscription;
import rx.observers.TestSubscriber;
import static com.stanfy.enroscar.goro.GoroImplTest.createGoroWith;
package com.stanfy.enroscar.goro.support;





@RunWith(RobolectricTestRunner.class)
@Config(constants = BuildConfig.class, sdk = 19)
public class RxGoroTest {

  private RxGoro rxGoro;
  private TestingQueues queues = new TestingQueues();

  @Before
  public void init() {
// Path: goro/src/test/java/com/stanfy/enroscar/goro/TestingQueues.java
// public class TestingQueues implements Queues {
// 
//   /** Scheduled tasks. */
//   private final ArrayList<Runnable> tasks = new ArrayList<>();
// 
//   /** Delegate executor. */
//   private Executor delegateExecutor = new Executor() {
//     @Override
//     public void execute(@SuppressWarnings("NullableProblems") final Runnable command) {
//       tasks.add(command);
//     }
//   };
// 
//   /** Last queue name. */
//   private String lastQueueName;
// 
//   @Override
//   public void setDelegateExecutor(final Executor delegate) {
//     delegateExecutor = delegate;
//   }
// 
//   @Override
//   public Executor getExecutor(final String queueName) {
//     lastQueueName = queueName;
//     return new TaskQueueExecutor(delegateExecutor);
//   }
// 
//   @Override
//   public void clear(final String queueName) {
//     lastQueueName = queueName;
//     tasks.clear();
//   }
// 
//   public String getLastQueueName() {
//     return lastQueueName;
//   }
// 
//   public void executeAll() {
//     for (Runnable command : tasks) {
//       command.run();
//     }
//     tasks.clear();
//   }
// 
// }
// 
// Path: goro/src/test/java/com/stanfy/enroscar/goro/GoroImplTest.java
// public static GoroImpl createGoroWith(TestingQueues queues) {
//   return new GoroImpl(queues);
// }


// Path: goro/src/test/java/com/stanfy/enroscar/goro/support/RxGoroTest.java
import com.stanfy.enroscar.goro.BuildConfig;
import com.stanfy.enroscar.goro.TestingQueues;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.robolectric.RobolectricTestRunner;
import org.robolectric.annotation.Config;
import rx.Observable;
import rx.Scheduler;
import rx.Subscription;
import rx.observers.TestSubscriber;
import static com.stanfy.enroscar.goro.GoroImplTest.createGoroWith;

package com.stanfy.enroscar.goro.support;





@RunWith(RobolectricTestRunner.class)
@Config(constants = BuildConfig.class, sdk = 19)
public class RxGoroTest {

  private RxGoro rxGoro;
  private TestingQueues queues = new TestingQueues();

  @Before
  public void init() {
    rxGoro = new RxGoro(createGoroWith(queues));