Package org.apache.pekko.serialization

Interface AsyncSerializer

All Known Implementing Classes:
AsyncSerializerWithStringManifest, AsyncSerializerWithStringManifestCS
public interface AsyncSerializer
Serializer that supports async serialization.

Only used for Pekko persistence journals that explicitly support async serializers.

Implementations should typically extend AsyncSerializerWithStringManifest or AsyncSerializerWithStringManifestCS that delegates synchronous calls to their async equivalents.

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<Object>
    fromBinaryAsync(byte[] bytes, String manifest)
    Produces an object from an array of bytes, with an optional type-hint.
    scala.concurrent.Future<byte[]>
    toBinaryAsync(Object o)
    Serializes the given object into an Array of Byte.

  • Method Details

    • fromBinaryAsync

      scala.concurrent.Future<Object> fromBinaryAsync(byte[] bytes, String manifest)
      Produces an object from an array of bytes, with an optional type-hint.

    • toBinaryAsync

      scala.concurrent.Future<byte[]> toBinaryAsync(Object o)
      Serializes the given object into an Array of Byte.

      Note that the array must not be mutated by the serializer after it has been used to complete the returned Future.