consume method

@override Future<Uint8List> consume(Context ctx, String urn, Execution exec, Uint8List inbound,)

Consume the input payload. urn Actual uniform resource Domain Name. execution Service reference. inbound Input arguments. Output payload

Implementation

@override
Future<Uint8List> consume(
    Context ctx, String urn, Execution exec, Uint8List inbound) async {
  final uri = Uri.parse(ctx.getAttribute(addressKey));
  final headers = <String, String>{
    'mesh-urn': urn,
    ...ctx.getAttribute(headerKey),
    ...ctx.attachments(),
  };
  final r = await hc
      .post(
        Uri.https(uri.authority, '/mpc/invoke'),
        body: inbound,
        headers: headers,
      )
      .timeout(exec.schema().timeout);
  if (r.statusCode != 200) {
    throw Status.system.err(r: '${r.statusCode}, ${r.reasonPhrase ?? ''}');
  }
  return r.bodyBytes;
}