约客多司机端
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
18034727885
2026-06-30 0d2dbecb03f2391f117cb14a96a481b3d442528d 
 rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java


@@ -1,10 +1,13 @@


package cn.sinata.rxnetty;




import android.app.*;


import android.app.Notification;


import android.app.NotificationChannel;


import android.app.NotificationManager;


import android.app.PendingIntent;


import android.app.Service;


import android.content.Context;


import android.content.Intent;


import android.graphics.Color;


import android.os.Build;


import android.os.IBinder;


import android.util.Log;




@@ -14,6 +17,7 @@


import java.nio.charset.Charset;


import java.util.ArrayList;


import java.util.concurrent.TimeUnit;




import cn.sinata.rxnetty.netStatus.NetChangeObserver;


import cn.sinata.rxnetty.netStatus.NetStateReceiver;


import cn.sinata.rxnetty.netStatus.NetUtils;


@@ -23,6 +27,7 @@


import io.reactivex.netty.channel.ObservableConnection;


import rx.Observable;


import rx.Subscriber;


import rx.android.schedulers.AndroidSchedulers;


import rx.functions.Action1;


import rx.functions.Func1;


import rx.schedulers.Schedulers;


@@ -258,7 +263,10 @@


            return;


        }


        //reconnect


        Observable.timer(3, TimeUnit.SECONDS).subscribe(new Action1<Long>() {


        Observable.timer(3, TimeUnit.SECONDS)


                .subscribeOn(Schedulers.io())


                .observeOn(AndroidSchedulers.mainThread())


                .subscribe(new Action1<Long>() {


            @Override


            public void call(Long aLong) {


                if (mConnection != null) {


@@ -268,7 +276,7 @@


                Log.i("CoreService", "sendHeart_websocket长连接断开，重新连接");


                connectServer();


            }


        });


                }, Throwable::printStackTrace);




    }