seyedjafariy

fun Context.coreComponent(): CoreComponent =
    if (applicationContext is CoreComponentProvider) {
        (applicationContext as CoreComponentProvider).core()
    } else {
        throw IllegalArgumentException("app class must implement CoreComponentProvider")
    }


fun View.coreComponent(): CoreComponent =
    context.coreComponent()

seyedjafariy

import android.app.Application
import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import dagger.Component
import dagger.Module
import javax.inject.Singleton

//these live in core module
@Module
object CoreModule {

seyedjafariy

import android.app.Application
import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import dagger.Component
import dagger.Module
import javax.inject.Singleton


@Module
object AppModule{

seyedjafariy

Observable.create(searchEvents)
                .throttle(10, TimeUnit.SECONDS)
                .subscribe(new Consumer<events>() {
                    @Override
                    public void accept(Events events) throws Exception {
                        
                    }
                });

seyedjafariy

Observable.range(0, 50)
          .buffer(10)
          .subscribe(integers -> {
              Log.d("tag", "list size recevied after buffering: "+integers.size());
          });

seyedjafariy

List<Integer> ints = Arrays.asList(1, 4, 7, 5, 1, 5, 4, 5, 1, 7);
Observable.fromIterable(ints)
                .distinct()
                .filter(integer-> integer % 2 == 0)
                .subscribe();

Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                for (int i = 0; i > 10; i++) {

seyedjafariy

Observable.just("Schedulers Test")
                .subscribeOn(Schedulers.computation())
                .subscribeOn(Schedulers.io())
                .subscribeOn(Schedulers.single())
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<String>() {
                    @Override
                    public void accept(String s) throws Exception {
                        

seyedjafariy

Observable.range(0, 50)
          .buffer(10)
          .subscribe(integers -> {
              Log.d("tag", "list size recevied after buffering: "+integers.size());
          });