AriasCreations/LibAC-dart
3
0
Fork 0
Code Issues 1 Pull requests Projects 3 Releases Packages Wiki Activity Actions

Adds a instruction to prevent automatically reconnecting the client to the server

Browse source
This commit is contained in:
zontreck 2024-05-24 15:48:50 -07:00
parent 4de135284f
commit 043010aad3
2 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
bin/client_test.dart
View file

@ -10,14 +10,14 @@ void main() async {
PacketClient client = PacketClient(); PacketClient client = PacketClient();
await client.startConnect("127.0.0.1"); await client.startConnect("127.0.0.1");
S2CResponse response = await client.send(C2SPing()); S2CResponse response = await client.send(C2SPing(), true);
CompoundTag tag = response.contents; CompoundTag tag = response.contents;
StringBuilder builder = StringBuilder(); StringBuilder builder = StringBuilder();
Tag.writeStringifiedNamedTag(tag, builder, 0); Tag.writeStringifiedNamedTag(tag, builder, 0);
print("Response from server: \n${builder}"); print("Response from server: \n${builder}");
await client.send(StopServerPacket()); await client.send(StopServerPacket(), false);
if (client.connected) await client.close(); if (client.connected) await client.close();
return; return;

3
lib/packets/packets.dart
View file

@ -91,7 +91,7 @@ class PacketClient {
/// Tries to send a packet to the connected server /// Tries to send a packet to the connected server
/// ///
/// On success, returns either, the decoded [S2CResponse], or on error a S2CResponse containing an error and a stacktrace as [StringTag] /// On success, returns either, the decoded [S2CResponse], or on error a S2CResponse containing an error and a stacktrace as [StringTag]
Future<S2CResponse> send(IPacket packet) async { Future<S2CResponse> send(IPacket packet, bool shouldReconnect) async {
if (!connected) { if (!connected) {
return S2CResponse(); return S2CResponse();
} }
@ -121,6 +121,7 @@ class PacketClient {
await onCompletion.future; await onCompletion.future;
await close(); await close();
await startConnect(lastIP); await startConnect(lastIP);
S2CResponse reply = S2CResponse(); S2CResponse reply = S2CResponse();
try { try {