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 'Сообщение доставлено'; |