Linloir/simple-chat-server
1
0
Fork 0
mirror of https://github.com/Linloir/Simple-TCP-Server.git synced 2025-12-16 23:48:11 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Changed recept method to async!!

Browse Source
This commit is contained in:
Linloir 2022-10-09 20:30:53 +08:00
parent 092a0cbb59
commit bb13789271
No known key found for this signature in database
GPG Key ID: 58EEB209A0F2C366
3 changed files with 11 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -3,6 +3,7 @@
.packages
.tmp/
.data/**
# Conventional directory for build output.
build/

3
lib/database.dart
View File

@ -1,7 +1,7 @@
/*
* @Author : Linloir
* @Date : 2022-10-06 16:15:01
* @LastEditTime : 2022-10-09 20:14:06
* @LastEditTime : 2022-10-09 20:28:49
* @Description :
*/
@ -482,7 +482,6 @@ class DataBaseHelper {
}
var filePath = '${Directory.current.path}/.data/files/$fileMd5';
await tempFile.copy(filePath);
tempFile.delete();
try {
await _database.insert(
'files',

24
lib/tcpcontroller/controller.dart
View File

@ -1,7 +1,7 @@
/*
* @Author : Linloir
* @Date : 2022-10-08 15:10:04
* @LastEditTime : 2022-10-09 17:55:26
* @LastEditTime : 2022-10-09 20:21:53
* @Description :
*/
@ -17,8 +17,6 @@ class TCPController {
//Stores the incoming bytes of the TCP connection temporarily
final List<int> buffer = [];
//Stores the fetched require temporarily
List<int> _requestBytes = [];
//Byte length for json object
int requestLength = 0;
@ -66,23 +64,19 @@ class TCPController {
var tempFile = File('${Directory.current.path}/.tmp/${DateTime.now().microsecondsSinceEpoch}')..createSync();
//Initialize payload transmission controller
_payloadStreamController = StreamController();
//Bind file to stream
_payloadStreamController.stream.listen(
(data) {
tempFile.writeAsBytesSync(data, mode: FileMode.append, flush: true);
},
onDone: () {
//Payload definetely ends after request is buffered
//Therefore transmit the request and payload to stream here
_inStreamController.add(TCPRequest(_requestBytes, tempFile));
//Create a future that listens to the status of the payload transmission
var payloadTransmission = Future(() async {
await for(var data in _payloadStreamController.stream) {
await tempFile.writeAsBytes(data, mode: FileMode.append, flush: true);
}
);
});
//Bind request construction on stream
_requestStreamController = StreamController();
_requestStreamController.stream.listen((requestBytes) {
//When request stream is closed by controller
//Request is intact, save to _request temporarily
_requestBytes = requestBytes;
payloadTransmission.then((_) {
_inStreamController.add(TCPRequest(requestBytes, tempFile));
});
});
}
else {