@override Future<void> terminate() { _incomingMessages.close(); _outgoingMessages.close(); return Future.value(); }