send method

  1. @override
Future<ResponsePacket?> send({
  1. required String pattern,
  2. required String id,
  3. Uint8List? payload,
})

Disconnect from the underlying transport.

Implementation

@override
Future<ResponsePacket?> send({
  required String pattern,
  required String id,
  Uint8List? payload,
}) async {
  if (_socket == null) {
    await connect();
  }
  final completer = Completer<ResponsePacket?>();
  _pendingRequests[id] = completer;
  _socket?.write(
    jsonEncode({
      'pattern': pattern,
      'id': id,
      'payload': payload != null ? base64Encode(payload) : null,
    }),
  );
  return completer.future;
}