response 참조 가능 하도록 오픈
This commit is contained in:
parent
777fac5d84
commit
bd945e5fbe
2 changed files with 4 additions and 1 deletions
|
|
@ -42,7 +42,6 @@ abstract class ProtobufClient extends Communicator
|
|||
_heartbeatChecker?.responsed();
|
||||
_heartbeatChecker = ResponseChecker.second(this, _heartbeatIntervalTime, (client) {
|
||||
if(_isAlive) {
|
||||
print('=== sendHartBeat');
|
||||
send(HeartBeat());
|
||||
_heartbeatChecker = ResponseChecker.second(this, _heartbeatWaitTime, (client) {
|
||||
if(_isAlive) {
|
||||
|
|
@ -172,6 +171,7 @@ class ResponseChecker<T> {
|
|||
late int _time;
|
||||
late Timer? _timer = null;
|
||||
late void Function(T) _notResponseListener;
|
||||
T get responser => _responser;
|
||||
ResponseChecker(this._responser, this._time, this._notResponseListener) {
|
||||
startTimer();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -16,6 +16,9 @@ void initialize() {
|
|||
getDataPath = getDataPath_;
|
||||
}
|
||||
|
||||
const int intMax = 0x7FFFFFFFFFFFFFFF;
|
||||
const int intMin = -0x8000000000000000;
|
||||
|
||||
Map<String, List<String>?> envArguments(List<String> arguments) {
|
||||
var dic = <String, List<String>?>{};
|
||||
var list = <String>[];
|
||||
|
|
|
|||
Loading…
Reference in a new issue