org.springframework.http.codec.protobuf

Class ProtobufDecoder.MessageDecoderFunction

java.lang.Object

org.springframework.http.codec.protobuf.ProtobufDecoder.MessageDecoderFunction

All Implemented Interfaces:

java.util.function.Function<DataBuffer,java.lang.Iterable<? extends Message>>

Enclosing class:

ProtobufDecoder

private class ProtobufDecoder.MessageDecoderFunction
extends java.lang.Object
implements java.util.function.Function<DataBuffer,java.lang.Iterable<? extends Message>>

Field Summary

Fields

Modifier and Type	Field and Description
private ResolvableType	elementType
private int	maxMessageSize
private int	messageBytesToRead
private int	offset
private DataBuffer	output

Constructor Summary

Constructors

Constructor and Description
MessageDecoderFunction(ResolvableType elementType, int maxMessageSize)

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<? extends Message>	apply(DataBuffer input)
void	discard()
private boolean	readMessageSize(DataBuffer input) Parse message size as a varint from the input stream, updating messageBytesToRead and offset fields if needed to allow processing of upcoming chunks.

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, identity

Field Detail

elementType

private final ResolvableType elementType

maxMessageSize

private final int maxMessageSize

output

@Nullable
private DataBuffer output

messageBytesToRead

private int messageBytesToRead

offset

private int offset

Constructor Detail

MessageDecoderFunction

public MessageDecoderFunction(ResolvableType elementType,
                              int maxMessageSize)

Method Detail

apply

public java.lang.Iterable<? extends Message> apply(DataBuffer input)

Specified by:

apply in interface java.util.function.Function<DataBuffer,java.lang.Iterable<? extends Message>>

readMessageSize

private boolean readMessageSize(DataBuffer input)

Parse message size as a varint from the input stream, updating messageBytesToRead and offset fields if needed to allow processing of upcoming chunks. Inspired from CodedInputStream#readRawVarint32(int, java.io.InputStream)

Returns:

{code true} when the message size is parsed successfully, {code false} when the message size is truncated

See Also:

Base 128 Varints

discard

public void discard()