Package io.servicetalk.serializer.api

Interface StreamingDeserializer<T>

Type Parameters:

T - The type of objects that can be deserialized.

All Known Subinterfaces:

StreamingSerializerDeserializer<T>

All Known Implementing Classes:

FixedLengthStreamingSerializer, VarIntLengthStreamingSerializer

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface StreamingDeserializer<T>

Deserialize a Publisher of Buffer to Publisher of StreamingDeserializer.

Method Summary

Modifier and Type	Method	Description
Publisher<T>	deserialize(Publisher<Buffer> serializedData, BufferAllocator allocator)	Deserialize a Publisher of Buffer into a Publisher of StreamingDeserializer.
default BlockingIterable<T>	deserialize(Iterable<Buffer> serializedData, BufferAllocator allocator)	Deserialize a Iterable of Buffer into a Iterable of StreamingDeserializer.

Method Details

deserialize

Publisher<T> deserialize(Publisher<Buffer> serializedData,
 BufferAllocator allocator)

Deserialize a Publisher of Buffer into a Publisher of StreamingDeserializer.

Parameters:

serializedData - the serialized stream of data represented in a Publisher of Buffer.

allocator - the BufferAllocator to use if allocation is required.

Returns:

The deserialized Publisher of StreamingDeserializers.

deserialize

default BlockingIterable<T> deserialize(Iterable<Buffer> serializedData,
 BufferAllocator allocator)

Deserialize a Iterable of Buffer into a Iterable of StreamingDeserializer.

Parameters:

serializedData - the serialized stream data represented in a Iterable of Buffer.

allocator - the BufferAllocator to use if allocation is required.

Returns:

The deserialized Iterable of StreamingDeserializers.