esiur/esiur-dart
2
0
Fork 0
mirror of https://github.com/esiur/esiur-dart.git synced 2025-05-06 12:02:57 +00:00
Code Issues Projects Releases Wiki Activity

TriggerChunk

Browse Source
This commit is contained in:
Ahmed Zamil 2020-01-16 03:52:32 +03:00
parent 3cd4abcdfc
commit 651f8b65dd
3 changed files with 9 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
lib/src/Core/AsyncReply.dart
View File

@ -177,30 +177,17 @@ class AsyncReply<T> implements Future<T>
triggerProgress(ProgressType type, int value, int max)
{
if (_resultReady)
return;
//lock (callbacksLock)
//{
_progressCallbacks.forEach((x) {
x(type, value, max);
});
//}
}
triggerChunk(T value)
{
if (_resultReady)
return;
//lock (callbacksLock)
//{
_chunkCallbacks.forEach((x) {
x(value);
});
//}
}

2
pubspec.yaml
View File

@ -1,6 +1,6 @@
name: esyur
description: Distributed Object Framework.
version: 1.1.2
version: 1.1.4
author: Ahmed Zamil <ahmed@dijlh.com>
homepage: https://github.com/esyur/esyur-dart

4
test/main.dart
View File

@ -7,8 +7,8 @@ main()
test("Connect to server", () async {
// connect to the server
var x = await Warehouse.get("iip://192.168.88.220:5000/sys/su", {"username": "admin", "password": "1234"
, "domain": "khalid.com"});
var x = await Warehouse.get("iip://localhost:5000/sys/su", {"username": "admin", "password": "1234"
, "domain": "example.com"});
x.instance.store.on("close", (x){
print("Closed");