Ребята, кто может посмотреть мой код? Написал взаимодействие RxJava и SQLite. Все работает, но мне кажется реализовал немного корява, по этому буду очень рад конструктивной критики и хорошему совету.

Тогда такой вопрос

Раньше работа с сетью была реализованна вот так:

final Internet internetItems = new Internet(getActivity());
       final ProgressDialog progressDialog = Global.NewProgressDialog(getActivity());

       final Handler handler = new Handler() {
           public void handleMessage(Message message) {
               try {
                   switch (message.what) {
                       case Global.HTTP_PENDING:
                           progressDialog.show();
                           break;
                       case Global.HTTP_FINISHED:
                           progressDialog.dismiss();

                           arrayList = Global.parsers.getCatalog(internetItems.result);
                           FullCatalog(arrayList);
                           break;
                   }
               } catch (Exception e) {
                   Utils.log("EXCEPTION = " + e);
               }
           }
       };

       internetItems.startURL("items.getCatalogFirstLevel", handler);

public boolean startURL(String packageprocedure, final Handler handler){

       connectivity = (ConnectivityManager)
               this.context.getSystemService(Context.CONNECTIVITY_SERVICE);
       if(connectivity==null){
           Toast.makeText(context, "Интернет отсутствует", Toast.LENGTH_SHORT).show();
           return false;
       }else {

           httpTask = new HTTPRequestTask();
           httpTask.execute(packageprocedure);

           final Thread thread = new Thread(new Runnable(){
               public void run(){
                   if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.CUPCAKE) {
                       while(getStatus() != AsyncTask.Status.FINISHED){
                           try {
                               TimeUnit.MILLISECONDS.sleep(100);
                               if(handler != null) {
                                   handler.sendEmptyMessage(Global.HTTP_PENDING);
                               }
                           } catch (InterruptedException e) {
                               e.printStackTrace();
                           }
                           if (getStatus() == AsyncTask.Status.FINISHED){
                               result = getURLString();
                               if(handler != null) {
                                   handler.sendEmptyMessage(Global.HTTP_FINISHED);
                               }
                           }
                       }
                   }
                   return;
               }
           }
           );
           thread.start();
       }
       return true;
   }

Как все это перевести на RxJava

Как поделится кодом?

Кому не трудно, подскажите

Используете плиз gist от github'a

А то  читать это крайне сложно

А в файле Java пойдет?

Там просто не много кода

нет

Хорошо, чуть позже

скину

Если не сложно посмотрите связку RxJava2 и SQLite. https://gist.github.com/Kosty63/93659d4ee6ad13881db0b7235ce2455f

парень, а ты учишься/работаешь?

буду очень рад конструктивной критики и хорошим советам.

Вопрос мне адресован? Или предыдущему оратору?)))