Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2025-01-09 04:09:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fns docs comments

Browse source
This commit is contained in:
sneurlax 2024-02-05 14:16:25 -06:00
parent 685690723a
commit 53d7143156
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/electrumx_rpc/subscribable_electrumx_client.dart
View file

@ -293,6 +293,7 @@ class SubscribableElectrumXClient {
return '{"jsonrpc": "2.0", "id": "$id","method": "$method","params": $paramString}\r\n';
}
/// Update the connection status and call the onConnectionStatusChanged callback if it exists.
void _updateConnectionStatus(bool connectionStatus) {
if (_isConnected != connectionStatus && onConnectionStatusChanged != null) {
onConnectionStatusChanged!(connectionStatus);
@ -300,6 +301,7 @@ class SubscribableElectrumXClient {
_isConnected = connectionStatus;
}
/// Called when the socket has data.
void _dataHandler(List<int> data) {
_responseData.addAll(data);
@ -320,6 +322,7 @@ class SubscribableElectrumXClient {
}
}
/// Called when the socket has a response.
void _responseHandler(Map<String, dynamic> response) {
// subscriptions will have a method in the response
if (response['method'] is String) {
@ -333,6 +336,7 @@ class SubscribableElectrumXClient {
_complete(id, result);
}
/// Called when the subscription has a response.
void _subscriptionHandler({
required Map<String, dynamic> response,
}) {
@ -356,6 +360,7 @@ class SubscribableElectrumXClient {
}
}
/// Called when the socket has an error.
void _errorHandler(Object error, StackTrace trace) {
_updateConnectionStatus(false);
Logging.instance.log(
@ -363,12 +368,14 @@ class SubscribableElectrumXClient {
level: LogLevel.Info);
}
/// Called when the socket is closed.
void _doneHandler() {
_updateConnectionStatus(false);
Logging.instance.log("SubscribableElectrumXClient called _doneHandler",
level: LogLevel.Info);
}
/// Complete a task with the given id and data.
void _complete(String id, dynamic data) {
if (_tasks[id] == null) {
return;
@ -385,6 +392,7 @@ class SubscribableElectrumXClient {
}
}
/// Add a task to the task list.
void _addTask({
required String id,
required Completer<dynamic> completer,
@ -392,6 +400,7 @@ class SubscribableElectrumXClient {
_tasks[id] = SocketTask(completer: completer, subscription: null);
}
/// Add a subscription task to the task list.
void _addSubscriptionTask({
required String id,
required ElectrumXSubscription subscription,
@ -399,6 +408,7 @@ class SubscribableElectrumXClient {
_tasks[id] = SocketTask(completer: null, subscription: subscription);
}
/// Write call to socket.
Future<dynamic> _call({
required String method,
List<dynamic> params = const [],