Updated on 2026-08-14
This commit is contained in:
parent
6e4d1f0079
commit
ef0a5f379d
6 changed files with 338 additions and 108 deletions
|
|
@ -143,8 +143,8 @@ public class ElectrumRequest {
|
|||
return "";
|
||||
}
|
||||
|
||||
public boolean isMethod(String methodName) throws JSONException {
|
||||
return jsRequestData.getString("method").equals(methodName);
|
||||
public boolean isMethod(String methodName) {
|
||||
return getMethod().equals(methodName);
|
||||
}
|
||||
|
||||
public JSONArray getParams() throws JSONException {
|
||||
|
|
|
|||
|
|
@ -52,6 +52,21 @@ public class ServerApiElectrum {
|
|||
private String host;
|
||||
private int port;
|
||||
|
||||
private int requestsCount=0;
|
||||
|
||||
public boolean hasRequests() {
|
||||
return requestsCount>0;
|
||||
}
|
||||
|
||||
private String error=null;
|
||||
public boolean isErrorOccured() {
|
||||
return error!=null;
|
||||
}
|
||||
|
||||
public void setErrorOccured(String error) {
|
||||
this.error=error;
|
||||
}
|
||||
|
||||
public interface ElectrumRequestDataListener {
|
||||
void onSuccess(ElectrumRequest electrumRequest);
|
||||
|
||||
|
|
@ -63,6 +78,7 @@ public class ServerApiElectrum {
|
|||
}
|
||||
|
||||
public void electrumRequestData(TangemContext ctx, ElectrumRequest electrumRequest) {
|
||||
requestsCount++;
|
||||
Observable<ElectrumRequest> checkElectrumDataObserver = Observable.just(electrumRequest)
|
||||
.doOnNext(electrumRequest1 -> doElectrumRequest(ctx, electrumRequest))
|
||||
|
||||
|
|
@ -84,6 +100,7 @@ public class ServerApiElectrum {
|
|||
@Override
|
||||
public void onNext(ElectrumRequest v) {
|
||||
if (electrumRequest.answerData != null) {
|
||||
requestsCount--;
|
||||
electrumRequestDataListener.onSuccess(electrumRequest);
|
||||
// Log.i(TAG, "electrumRequestData " + electrumRequest.getMethod() + " onNext != null");
|
||||
} else {
|
||||
|
|
@ -282,4 +299,5 @@ public class ServerApiElectrum {
|
|||
return "Electrum, " + host + ":" + String.valueOf(port);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue