Module kflow_buffer

This module collects messages into a list, or concatenates lists of messages.

Behaviours: kflow_gen_aggregate.

Description

This module collects messages into a list, or concatenates lists of messages.

Input message format:

   Msg \ [Msg]

Output message format:

   [Msg]

The following optional parameters can be configured:

Type: non_neg_integer(). Buffer will be flushed when it collects this many messages. By default equals 100.

Type: non_neg_integer() | undefined. Buffer will be flushed when it collects this many bytes of data. By default this is unlimited.

   {aggregate, kflow_buffer, #{}}

config() = #{max_messages => non_neg_integer(), max_size => non_neg_integer() | undefined}

Generated by EDoc