class Movie::Remote::InboundFrameBatchDecoder

Movie::Remote::InboundFrameBatchDecoder
Reference
Object

Overview

Decodes one blocking frame followed by only the complete frames already retained by the connection reader. The returned array is reused and is valid until the next call.

Defined in:

movie/remote/inbound_frame_reader.cr

Constant Summary

DEFAULT_BATCH_SIZE = 128

Constructors

.new(source : IO, payload_decoder : JsonPayloadDecoder | Nil = nil, batch_size : Int32 = DEFAULT_BATCH_SIZE, buffer_size : Int32 = InboundFrameReader::DEFAULT_BUFFER_SIZE)

Instance Method Summary

#next_batch : Array(WireEnvelope) | Nil

Constructor Detail

def self.new(source : IO, payload_decoder : JsonPayloadDecoder | Nil = nil, batch_size : Int32 = DEFAULT_BATCH_SIZE, buffer_size : Int32 = InboundFrameReader::DEFAULT_BUFFER_SIZE) #

[View source]

Instance Method Detail

def next_batch : Array(WireEnvelope) | Nil #

[View source]