ericntd

DiscoverFeedMainInteractor

@Override
  protected void didBecomeActive() {
    super.didBecomeActive();
    discoverBagelRefreshStream = BehaviorSubject.create();
    discoverManager.addGiveTakeItemEventListener(this);
    /*
    If something goes wrong witht the download of GiveTakes & RisingGiveTakes,
    discoverMatchRepository.getGiveTakesDownloaded() will never return

ericntd

GetBagelConnectionUseCase

operator fun invoke(): Flowable<List<ConnectionHolder>> {
        return Flowables.zip(
            subscriptionRepository.getActiveSubscription(),
            likesYouMatchCountRepository.getLocalCount()
        )
        .firstOrError()
        .map { pair ->
            val result = mutableListOf<ConnectionHolder>()

ericntd

private void startSyncRunnable(QueuedSync queuedSync) {
    //...

    featureFlagRepository.refresh(true)
            .subscribe(() -> {
              if (featureFlagRepository.isEnabled(FeatureConstants.FASTER_APP_START)) {
                long startTime = System.currentTimeMillis();
                List<Completable> completableList = new ArrayList<>();
                completableList.add(priceRepository.refresh());

ericntd

@Override
  public Flow<List<QuestionWithRelations>> readMcqAnswers1() {
    final String _sql = "SELECT * FROM question";
    final RoomSQLiteQuery _statement = RoomSQLiteQuery.acquire(_sql, 0);
    return CoroutinesRoom.createFlow(__db, false, new String[]{"option","answer","question"}, new Callable<List<QuestionWithRelations>>() {
      @Override
      public List<QuestionWithRelations> call() throws Exception {
        final Cursor _cursor = DBUtil.query(__db, _statement, true, null);
        try {
          final int _cursorIndexOfId = CursorUtil.getColumnIndexOrThrow(_cursor, "question_id");

ericntd

class MatchPresentationLogics(
    private val bagel: Bagel,
    private val banState: Observable<BanState>
) {
   init {
       banState.subscribe {
           // do what's necessary
       }
 }

ericntd

@DependencyHolder
class CatDependencyHolder {
    @Provides
    @AppScope
    fun retrofit(): Retrofit {
        return Retrofit.Builder()
            .baseUrl(BuildConfig.BASE_URL)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .build()

ericntd

class MainActivity : AppCompatActivity(), MainView {
    @RequestDependency
    lateinit var presenter: MainPresenter

ericntd

@AppScope
class CatRepository @Contribute constructor(private val api: CatApi) {
    fun getCat(): Single<CatResponse> {
        return api.getCat()
            .subscribeOn(Schedulers.io())
    }
}

ericntd

@Injector(modules = [CatDependencyHolder::class, ContextDependencyHolder::class])
@AppScope
interface MyAppInjector {
    // aka. plus
    fun plusMainActivityInjector(mainActivityDependencyHolder: MainActivityInjector.MainActivityDependencyHolder): MainActivityInjector
}

ericntd

@DependencyHolder
class CatDependencyHolder {
    @Provides
    @AppScope
    fun retrofit(): Retrofit {
        return Retrofit.Builder()
            .baseUrl(BuildConfig.BASE_URL)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .build()