based on https://morningcoffee.io/stable-pagination.html.
In order for this to work I had to use uuidgen -t to generate time-based uuids otherwise the ordering would be messed up after 2-3 pages in.
sqlite3 pagination.db| import 'dart:io' as io; | |
| import 'package:flutter_test/flutter_test.dart'; | |
| import 'package:integration_test/integration_test.dart'; | |
| import 'src/util/screenshot.dart'; | |
| void main() { | |
| final binding = IntegrationTestWidgetsFlutterBinding.ensureInitialized(); |
| import 'dart:async'; | |
| import 'dart:math' as math; | |
| import 'dart:typed_data' as td; | |
| import 'package:meta/meta.dart'; | |
| /// {@template chunker} | |
| /// Chunker stream transformer | |
| /// {@endtemplate} | |
| @immutable |
| /* ... */ | |
| mixin _LocalStorageAPI on _LocalStorageCache { | |
| Future<String?> getString(String key) => _eval<String?>((db) => db.getString(key)); | |
| Future<void> setString(String key, String value) => _eval<void>((db) => db.setString(key, value)); | |
| } |
| import 'dart:async'; | |
| import 'dart:collection'; | |
| import 'dart:developer' as developer; | |
| /// Async callback | |
| typedef EventCallback = FutureOr<void> Function(); | |
| /// {@template event_queue} | |
| /// An event queue is a queue of [EventCallback]s that are executed in order. | |
| /// {@endtemplate} |
based on https://morningcoffee.io/stable-pagination.html.
In order for this to work I had to use uuidgen -t to generate time-based uuids otherwise the ordering would be messed up after 2-3 pages in.
sqlite3 pagination.db| /* | |
| * Filter example pass controller through constructor | |
| * https://gist.github.com/PlugFox/1e011d3b3737d59697e09bc6e59f422f | |
| * https://dartpad.dev/1e011d3b3737d59697e09bc6e59f422f | |
| * Matiunin Mikhail <[email protected]>, 19 May 2022 | |
| */ | |
| import 'dart:async'; | |
| import 'dart:math' as math; |
Найти http, https, socks 5 прокси для Канады в количестве 10 штук:
docker run --rm -it --name proxy_broker bluet/proxybroker2 find --types HTTP HTTPS SOCKS5 --limit 10 --countries CAПомощь:
docker run --rm -it --name proxy_broker bluet/proxybroker2 find --help| class ValueStream<T> extends Stream<T> { | |
| Stream<T> _source; | |
| T _lastValue; | |
| T get value => _lastValue; | |
| Stream<T> get _stream async* { | |
| yield value; | |
| yield* _source; |
| Stream<String> _isolateHandler(dynamic data, Map<String, dynamic> context) async* { | |
| if (data is! String) { | |
| throw 'Получены неизвестные данные \'${data.toString()}\'!'; | |
| } | |
| String telegramMessage = data as String; | |
| final Telegram tg = context['tg'] as Telegram; | |
| try { | |
| final bool sendResult = await tg.send(telegramMessage); | |
| if (!sendResult) throw UnsupportedError('Сообщение не доставлено'); | |
| yield 'Сообщение доставлено'; |