Package io.servicetalk.http.api

Interface HttpStreamingDeserializer<T>

Type Parameters:

T - The type of objects to serialize.

All Known Subinterfaces:

HttpStreamingSerializerDeserializer<T>

public interface HttpStreamingDeserializer<T>

HTTP request/response deserialization for streaming payload bodies.

Method Summary

Modifier and Type	Method	Description
Publisher<T>	deserialize(HttpHeaders headers, Publisher<Buffer> payload, BufferAllocator allocator)	Deserialize a Publisher of Objects into a Publisher of type HttpStreamingDeserializer.
default BlockingIterable<T>	deserialize(HttpHeaders headers, BlockingIterable<Buffer> payload, BufferAllocator allocator)	Deserialize a BlockingIterable of Objects into a BlockingIterable of type HttpStreamingDeserializer.

Method Details

deserialize

Publisher<T> deserialize(HttpHeaders headers,
 Publisher<Buffer> payload,
 BufferAllocator allocator)

Deserialize a Publisher of Objects into a Publisher of type HttpStreamingDeserializer.

Parameters:

headers - The HttpHeaders associated with the payload.

payload - Provides the Objects to deserialize.

allocator - Used to allocate Buffers if necessary during deserialization.

Returns:

a Publisher of type HttpStreamingDeserializer which is the result of the deserialization.

deserialize

default BlockingIterable<T> deserialize(HttpHeaders headers,
 BlockingIterable<Buffer> payload,
 BufferAllocator allocator)

Deserialize a BlockingIterable of Objects into a BlockingIterable of type HttpStreamingDeserializer.

Parameters:

headers - The HttpHeaders associated with the payload.

payload - Provides the Objects to deserialize. The contents are assumed to be in memory, otherwise this method may block.

allocator - Used to allocate Buffers if necessary during deserialization.

Returns:

a BlockingIterable of type HttpStreamingDeserializer which is the result of the deserialization.