Compare commits
3 Commits
2a469e10e8
...
5e867e30ee
Author | SHA1 | Date | |
---|---|---|---|
5e867e30ee | |||
3d3b047097 | |||
7e55015948 |
@ -6,10 +6,3 @@ linter:
|
||||
use_setters_to_change_properties: false
|
||||
avoid_positional_boolean_parameters: false
|
||||
avoid_bool_literals_in_conditional_expressions: false
|
||||
|
||||
analyzer:
|
||||
exclude:
|
||||
- "**/*.g.dart"
|
||||
- "**/*.freezed.dart"
|
||||
- "test/"
|
||||
- "integration_test/"
|
||||
|
18
flake.lock
18
flake.lock
@ -2,11 +2,11 @@
|
||||
"nodes": {
|
||||
"flake-utils": {
|
||||
"locked": {
|
||||
"lastModified": 1667395993,
|
||||
"narHash": "sha256-nuEHfE/LcWyuSWnS8t12N1wc105Qtau+/OdUAjtQ0rA=",
|
||||
"lastModified": 1656065134,
|
||||
"narHash": "sha256-oc6E6ByIw3oJaIyc67maaFcnjYOz1mMcOtHxbEf9NwQ=",
|
||||
"owner": "numtide",
|
||||
"repo": "flake-utils",
|
||||
"rev": "5aed5285a952e0b949eb3ba02c12fa4fcfef535f",
|
||||
"rev": "bee6a7250dd1b01844a2de7e02e4df7d8a0a206c",
|
||||
"type": "github"
|
||||
},
|
||||
"original": {
|
||||
@ -17,16 +17,16 @@
|
||||
},
|
||||
"nixpkgs": {
|
||||
"locked": {
|
||||
"lastModified": 1667610399,
|
||||
"narHash": "sha256-XZd0f4ZWAY0QOoUSdiNWj/eFiKb4B9CJPtl9uO9SYY4=",
|
||||
"owner": "NixOS",
|
||||
"lastModified": 1657540956,
|
||||
"narHash": "sha256-ihGbOFWtAkENwxBE5kV/yWt2MncvW+BObLDsmxCLo/Q=",
|
||||
"owner": "NANASHI0X74",
|
||||
"repo": "nixpkgs",
|
||||
"rev": "1dd8696f96db47156e1424a49578fe7dd4ce99a4",
|
||||
"rev": "043de04db8a6b0391b3fefaaade160514d866946",
|
||||
"type": "github"
|
||||
},
|
||||
"original": {
|
||||
"owner": "NixOS",
|
||||
"ref": "nixpkgs-unstable",
|
||||
"owner": "NANASHI0X74",
|
||||
"ref": "flutter-3-0-0",
|
||||
"repo": "nixpkgs",
|
||||
"type": "github"
|
||||
}
|
||||
|
@ -1,7 +1,7 @@
|
||||
{
|
||||
description = "moxlib";
|
||||
inputs = {
|
||||
nixpkgs.url = "github:NixOS/nixpkgs/nixpkgs-unstable";
|
||||
nixpkgs.url = "github:NANASHI0X74/nixpkgs/flutter-3-0-0";
|
||||
flake-utils.url = "github:numtide/flake-utils";
|
||||
};
|
||||
|
||||
|
@ -1,16 +0,0 @@
|
||||
/// A wrapper around List<T>.firstWhere that does not throw but instead just
|
||||
/// returns true if [test] returns true for an element or false if [test] never
|
||||
/// returned true.
|
||||
bool listContains<T>(List<T> list, bool Function(T element) test) {
|
||||
return firstWhereOrNull<T>(list, test) != null;
|
||||
}
|
||||
|
||||
/// A wrapper around [List<T>.firstWhere] that does not throw but instead just
|
||||
/// return null if [test] never returned true
|
||||
T? firstWhereOrNull<T>(List<T> list, bool Function(T element) test) {
|
||||
try {
|
||||
return list.firstWhere(test);
|
||||
} catch(e) {
|
||||
return null;
|
||||
}
|
||||
}
|
@ -1,5 +1,5 @@
|
||||
library moxlib;
|
||||
|
||||
export 'awaitabledatasender.dart';
|
||||
export 'lists.dart';
|
||||
export 'math.dart';
|
||||
export 'src/awaitabledatasender.dart';
|
||||
export 'src/math.dart';
|
||||
export 'src/result.dart';
|
||||
|
@ -30,12 +30,12 @@ class DataWrapper<T extends JsonImplementation> {
|
||||
/// The actual data.
|
||||
final T data;
|
||||
|
||||
Map<String, dynamic> toJson() => {
|
||||
'id': id,
|
||||
'data': data.toJson()
|
||||
};
|
||||
Map<String, dynamic> toJson() => {'id': id, 'data': data.toJson()};
|
||||
|
||||
static DataWrapper fromJson<T extends JsonImplementation>(Map<String, dynamic> json) => DataWrapper<T>(
|
||||
static DataWrapper fromJson<T extends JsonImplementation>(
|
||||
Map<String, dynamic> json,
|
||||
) =>
|
||||
DataWrapper<T>(
|
||||
json['id']! as String,
|
||||
json['data']! as T,
|
||||
);
|
||||
@ -49,10 +49,8 @@ class DataWrapper<T extends JsonImplementation> {
|
||||
///
|
||||
/// awaiting [sendData] will return a [Future] that will resolve to the reresponse when
|
||||
/// received via [onData].
|
||||
abstract class AwaitableDataSender<
|
||||
S extends JsonImplementation,
|
||||
R extends JsonImplementation
|
||||
> {
|
||||
abstract class AwaitableDataSender<S extends JsonImplementation,
|
||||
R extends JsonImplementation> {
|
||||
@mustCallSuper
|
||||
AwaitableDataSender();
|
||||
|
||||
@ -82,7 +80,11 @@ abstract class AwaitableDataSender<
|
||||
/// Sends [data] using [sendDataImpl]. If [awaitable] is true, then a
|
||||
/// Future will be returned that can be used to await a response. If it
|
||||
/// is false, then null will be imediately resolved.
|
||||
Future<R?> sendData(S data, { bool awaitable = true, @visibleForTesting String? id }) async {
|
||||
Future<R?> sendData(
|
||||
S data, {
|
||||
bool awaitable = true,
|
||||
@visibleForTesting String? id,
|
||||
}) async {
|
||||
// ignore: no_leading_underscores_for_local_identifiers
|
||||
final _id = id ?? _uuid.v4();
|
||||
var future = Future<R?>.value();
|
24
lib/src/result.dart
Normal file
24
lib/src/result.dart
Normal file
@ -0,0 +1,24 @@
|
||||
/// Holds a value of either [T] or [V].
|
||||
class Result<T, V> {
|
||||
/// Constructs a result. [_data] must be either of type [T] or [V].
|
||||
const Result(this._data)
|
||||
: assert(
|
||||
_data is T || _data is V,
|
||||
'Invalid data type $_data: Must be either $T or $V',
|
||||
);
|
||||
final dynamic _data;
|
||||
|
||||
/// Returns true if the data contained within is of type [S]. If not, returns false.
|
||||
bool isType<S>() => _data is S;
|
||||
|
||||
/// Returns the data contained within cast to [S]. Before doing this call, it's recommended
|
||||
/// to check isType<S>() first.
|
||||
S get<S>() {
|
||||
assert(_data is S, 'Data is not $S');
|
||||
|
||||
return _data as S;
|
||||
}
|
||||
|
||||
/// Returns the runtime type of the data.
|
||||
Object get dataRuntimeType => _data.runtimeType;
|
||||
}
|
@ -1,11 +1,11 @@
|
||||
name: moxlib
|
||||
description: A collection of code for sharing between various moxxy libraries. Not inteded for outside use.
|
||||
version: 0.1.5
|
||||
description: A collection of code for sharing between various moxxy libraries. Not intended for outside use.
|
||||
version: 0.2.0
|
||||
homepage: https://codeberg.org/moxxy/moxlib
|
||||
publish_to: https://git.polynom.me/api/packages/Moxxy/pub
|
||||
|
||||
environment:
|
||||
sdk: ">=2.17.0-266.1.beta <3.0.0"
|
||||
sdk: ">=2.17.0 <3.0.0"
|
||||
|
||||
dependencies:
|
||||
logging: ^1.0.2
|
||||
|
@ -1,29 +1,23 @@
|
||||
import "package:moxlib/awaitabledatasender.dart";
|
||||
|
||||
import "package:test/test.dart";
|
||||
import 'package:moxlib/moxlib.dart';
|
||||
import 'package:test/test.dart';
|
||||
|
||||
class TestDataType implements JsonImplementation {
|
||||
final String data;
|
||||
|
||||
TestDataType(this.data);
|
||||
|
||||
@override
|
||||
Map<String, dynamic> toJson() => {
|
||||
"data": data
|
||||
};
|
||||
factory TestDataType.fromJson(Map<String, dynamic> json) =>
|
||||
TestDataType(json['data']! as String);
|
||||
|
||||
factory TestDataType.fromJson(Map<String, dynamic> json) => TestDataType(
|
||||
json["data"]!
|
||||
);
|
||||
final String data;
|
||||
|
||||
@override
|
||||
Map<String, dynamic> toJson() => {'data': data};
|
||||
}
|
||||
|
||||
class FakeAwaitableDataSender<
|
||||
S extends JsonImplementation,
|
||||
R extends JsonImplementation
|
||||
> extends AwaitableDataSender<S, R> {
|
||||
final void Function()? onAddFunc;
|
||||
class FakeAwaitableDataSender<S extends JsonImplementation,
|
||||
R extends JsonImplementation> extends AwaitableDataSender<S, R> {
|
||||
FakeAwaitableDataSender({this.onAddFunc}) : super();
|
||||
|
||||
FakeAwaitableDataSender({ this.onAddFunc }) : super();
|
||||
final void Function()? onAddFunc;
|
||||
|
||||
@override
|
||||
Future<void> sendDataImpl(DataWrapper data) async {}
|
||||
@ -35,39 +29,41 @@ class FakeAwaitableDataSender<
|
||||
}
|
||||
|
||||
void main() {
|
||||
test("Sending an event without awaiting it", () async {
|
||||
test('Sending an event without awaiting it', () async {
|
||||
final handler = FakeAwaitableDataSender<TestDataType, TestDataType>();
|
||||
final result = await handler.sendData(TestDataType("hallo"), awaitable: false);
|
||||
final result =
|
||||
await handler.sendData(TestDataType('hallo'), awaitable: false);
|
||||
|
||||
expect(result, null);
|
||||
expect(handler.getAwaitables().length, 0);
|
||||
});
|
||||
|
||||
test("Sending an event without awaiting it", () async {
|
||||
test('Sending an event without awaiting it', () async {
|
||||
final handler = FakeAwaitableDataSender<TestDataType, TestDataType>();
|
||||
const id = "abc123";
|
||||
final result = handler.sendData(TestDataType("hallo"), awaitable: true, id: id);
|
||||
await handler.onData(DataWrapper(id, TestDataType("welt")));
|
||||
const id = 'abc123';
|
||||
final result =
|
||||
handler.sendData(TestDataType('hallo'), awaitable: true, id: id);
|
||||
await handler.onData(DataWrapper(id, TestDataType('welt')));
|
||||
|
||||
expect((await result)!.data, "welt");
|
||||
expect((await result)!.data, 'welt');
|
||||
expect(handler.getAwaitables().length, 0);
|
||||
});
|
||||
|
||||
test("Queue multiple data packets and resolve in reverse order", () async {
|
||||
int i = 0;
|
||||
test('Queue multiple data packets and resolve in reverse order', () async {
|
||||
var i = 0;
|
||||
final handler = FakeAwaitableDataSender<TestDataType, TestDataType>(
|
||||
onAddFunc: () {
|
||||
i++;
|
||||
expect(i <= 2, true);
|
||||
}
|
||||
},
|
||||
);
|
||||
final a = handler.sendData(TestDataType("1"), id: "1");
|
||||
final b = handler.sendData(TestDataType("2"), id: "2");
|
||||
final a = handler.sendData(TestDataType('1'), id: '1');
|
||||
final b = handler.sendData(TestDataType('2'), id: '2');
|
||||
|
||||
await handler.onData(DataWrapper("2", TestDataType("4")));
|
||||
await handler.onData(DataWrapper("1", TestDataType("1")));
|
||||
await handler.onData(DataWrapper('2', TestDataType('4')));
|
||||
await handler.onData(DataWrapper('1', TestDataType('1')));
|
||||
|
||||
expect((await a)!.data, "1");
|
||||
expect((await b)!.data, "4");
|
||||
expect((await a)!.data, '1');
|
||||
expect((await b)!.data, '4');
|
||||
});
|
||||
}
|
||||
|
@ -1,10 +1,9 @@
|
||||
import "package:moxlib/math.dart";
|
||||
|
||||
import "package:test/test.dart";
|
||||
import 'package:moxlib/moxlib.dart';
|
||||
import 'package:test/test.dart';
|
||||
|
||||
void main() {
|
||||
group("implies", () {
|
||||
test("Truth table test", () {
|
||||
group('implies', () {
|
||||
test('Truth table test', () {
|
||||
expect(implies(true, true), true);
|
||||
expect(implies(true, false), false);
|
||||
expect(implies(false, true), true);
|
||||
|
Loading…
Reference in New Issue
Block a user