Package com.here.platform.data.client.converters

Interface PartitionDecoder

All Superinterfaces:
Serializable
All Known Subinterfaces:
PartitionConverter
All Known Implementing Classes:
ProtobufPartitionConverter
public interface PartitionDecoder extends Serializable

  • Method Summary

    Modifier and Type
    Method
    Description
    byte[]
    decode(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)
     
    org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>
    decode(com.here.platform.data.client.scaladsl.Partition partition, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> byteSource, scala.concurrent.ExecutionContext ctx, org.apache.pekko.stream.Materializer materializer)
     

  • Method Details

    • decode

      byte[] decode(com.here.platform.data.client.scaladsl.Partition partition, byte[] data)

    • decode

      org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> decode(com.here.platform.data.client.scaladsl.Partition partition, org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> byteSource, scala.concurrent.ExecutionContext ctx, org.apache.pekko.stream.Materializer materializer)