Package io.servicetalk.serializer.utils

Class FramedDeserializerOperator<T>

java.lang.Object

io.servicetalk.serializer.utils.FramedDeserializerOperator<T>

Type Parameters:

T - The type to serialize/deserialize.

All Implemented Interfaces:

PublisherOperator<Buffer,Iterable<T>>, Function<PublisherSource.Subscriber<? super Iterable<T>>,PublisherSource.Subscriber<? super Buffer>>

public final class FramedDeserializerOperator<T>
extends Object
implements PublisherOperator<Buffer,Iterable<T>>

Utility which helps implementations of StreamingDeserializer leverage a Deserializer and apply a framing to define the boundaries of each object.

Constructor Summary

Constructors

Constructor	Description
FramedDeserializerOperator(Deserializer<T> deserializer, Supplier<BiFunction<Buffer,BufferAllocator,Buffer>> deframerSupplier, BufferAllocator allocator)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
PublisherSource.Subscriber<? super Buffer>	apply(PublisherSource.Subscriber<? super Iterable<T>> subscriber)	Implementation of this operator.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Details

FramedDeserializerOperator

public FramedDeserializerOperator(Deserializer<T> deserializer,
 Supplier<BiFunction<Buffer,BufferAllocator,Buffer>> deframerSupplier,
 BufferAllocator allocator)

Create a new instance.

Parameters:

deserializer - The Deserializer to deserialize each individual item.

deframerSupplier - Provides a Function for each subscribe which is invoked each time a Buffer arrives. The Function is expected to return the a Buffer with enough data that the Deserializer can deserialize, or null if there isn't enough data.

allocator - Used to allocate Buffers to aggregate data across deserialization calls if necessary.

Method Details

apply

public PublisherSource.Subscriber<? super Buffer> apply(PublisherSource.Subscriber<? super Iterable<T>> subscriber)

Description copied from interface: PublisherOperator

Implementation of this operator. See PublisherOperator for definition of an operator.

Specified by:

apply in interface Function<PublisherSource.Subscriber<? super Iterable<T>>,PublisherSource.Subscriber<? super Buffer>>

Specified by:

apply in interface PublisherOperator<Buffer,Iterable<T>>

Parameters:

subscriber - PublisherSource.Subscriber that subscribed to this operator.

Returns:

PublisherSource.Subscriber that is used to subscribe to the Publisher that this operator is applied to.