Queue Strategy

1

See also

Other queue_strategies: byte_size_strategy, no_backpressure_strategy, object_length_strategy

Active bindings

highwater_mark

A number representing the queue size at which a stream will stop attempting to receive more chunks

Methods

Public methods

• QueueStrategy$new()

• QueueStrategy$size()

---

Method new()

Create a new queue strategy

Usage

QueueStrategy$new(highwater_mark, size_algorithm)

Arguments

highwater_mark

number denoting when a stream should stop asking for more data

size_algorithm

function that is used to measure the size of the stream queue

---

Method size()

A function that is applied to a chunk in order to determine its size.

Usage

QueueStrategy$size(chunk)

Arguments

chunk

a data chunk

Returns

numeric vector