Kieran/zap-stream-flutter
1
0
Fork 0
mirror of https://github.com/nostrlabs-io/zap-stream-flutter.git synced 2025-06-16 03:58:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: chat raiding

Browse Source 
closes #1
This commit is contained in:
Kieran
2025-05-14 11:39:10 +01:00
parent 42d9293ecb
commit 1f8124b708
8 changed files with 491 additions and 191 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
lib/rx_filter.dart
View File

@ -1,3 +1,4 @@
import 'dart:async';
import 'dart:collection';
import 'dart:developer' as developer;
@ -29,6 +30,7 @@ class RxFilter<T> extends StatefulWidget {
class _RxFilter<T> extends State<RxFilter<T>> {
late NdkResponse _response;
late StreamSubscription _listener;
HashMap<String, (int, T)>? _events;
@override
@ -45,19 +47,21 @@ class _RxFilter<T> extends State<RxFilter<T>> {
ndk.requests.closeSubscription(_response.requestId);
});
}
_response.stream
_listener = _response.stream
.bufferTime(const Duration(milliseconds: 500))
.where((events) => events.isNotEmpty)
.handleError((e) {
developer.log("RX:ERROR $e");
})
.listen((events) {
setState(() {
developer.log(
"RX:GOT ${events.length} events for ${widget.filters}",
);
events.forEach(_replaceInto);
});
if (context.mounted) {
setState(() {
developer.log(
"RX:GOT ${events.length} events for ${widget.filters}",
);
events.forEach(_replaceInto);
});
}
});
}
@ -88,6 +92,7 @@ class _RxFilter<T> extends State<RxFilter<T>> {
super.dispose();
developer.log("RX:CLOSING ${widget.filters}");
_listener.cancel();
ndk.requests.closeSubscription(_response.requestId);
}