fix hang on shutdown

This commit is contained in:
Christien Rioux 2024-03-02 18:12:55 -05:00
parent a04d4e12c5
commit 89c51ff069

View File

@ -479,6 +479,7 @@ Stream<T> processStreamJson<T>(
} }
case messageStreamClose: case messageStreamClose:
{ {
port.close();
break; break;
} }
default: default:
@ -1551,6 +1552,7 @@ class VeilidFFI extends Veilid {
final recvPort = ReceivePort('shutdown_veilid_core'); final recvPort = ReceivePort('shutdown_veilid_core');
final sendPort = recvPort.sendPort; final sendPort = recvPort.sendPort;
_shutdownVeilidCore(sendPort.nativePort); _shutdownVeilidCore(sendPort.nativePort);
return processFutureVoid(recvPort.first); return processFutureVoid(recvPort.first);
} }