Package io.servicetalk.serializer.api

Interface StreamingSerializer<T>

Type Parameters:

T - The type of objects that can be serialized.

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 StreamingSerializer<T>

Serialize a Publisher of StreamingSerializer to Publisher of Buffer.

Method Summary

Modifier and Type	Method	Description
Publisher<Buffer>	serialize(Publisher<T> toSerialize, BufferAllocator allocator)	Serialize a Publisher of StreamingSerializers into a Publisher of Buffer.
default PayloadWriter<T>	serialize(PayloadWriter<Buffer> writer, BufferAllocator allocator)	Serialize a PayloadWriter of StreamingSerializers into a PayloadWriter of Buffer.
default BlockingIterable<Buffer>	serialize(Iterable<T> toSerialize, BufferAllocator allocator)	Serialize a Iterable of StreamingSerializers into a Iterable of Buffer.

Method Details

serialize

Publisher<Buffer> serialize(Publisher<T> toSerialize,
 BufferAllocator allocator)

Serialize a Publisher of StreamingSerializers into a Publisher of Buffer.

Parameters:

toSerialize - the deserialized stream of data represented in a Publisher of StreamingSerializer.

allocator - the BufferAllocator to use if allocation is required.

Returns:

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

serialize

default BlockingIterable<Buffer> serialize(Iterable<T> toSerialize,
 BufferAllocator allocator)

Serialize a Iterable of StreamingSerializers into a Iterable of Buffer.

Parameters:

toSerialize - the deserialized stream of data represented in a Iterable of StreamingSerializer.

allocator - the BufferAllocator to use if allocation is required.

Returns:

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

serialize

default PayloadWriter<T> serialize(PayloadWriter<Buffer> writer,
 BufferAllocator allocator)

Serialize a PayloadWriter of StreamingSerializers into a PayloadWriter of Buffer.

Parameters:

writer - The PayloadWriter used to write the result of serialization to.

allocator - the BufferAllocator to use if allocation is required.

Returns:

a PayloadWriter where you can write StreamingSerializers to.