withTaskPayloadEncoder function

ResultBackend withTaskPayloadEncoder(
  1. ResultBackend backend,
  2. TaskPayloadEncoderRegistry registry
)

Wraps a ResultBackend to encode/decode payloads via registry.

Implementation

ResultBackend withTaskPayloadEncoder(
  ResultBackend backend,
  TaskPayloadEncoderRegistry registry,
) {
  if (backend is EncodingResultBackend && backend.registry == registry) {
    return backend;
  }
  return EncodingResultBackend(backend, registry);
}