NAME

 Data::AnyXfer::Elastic::Import::Utils::Buffer - Buffer class

DESCRIPTION

 This module provides methods for buffer action

SYNOPSIS

    use Data::AnyXfer::Elastic::Import::Utils::Buffer;

    my $buffer = Data::AnyXfer::Elastic::Import::Utils::Buffer->new(
        callback => $sub );

    # push data into buffer
    $buffer->push(@data);

    # called automatically when more than c<max_size> items have
    # been added to the buffer using c<push>
    $buffer->flush();

ATTRIBUTES

max_size

 size of the buffer, default is 200

callback

    # Callback must follow the call signature
    $callback->(@data_entries);

 callback function which will process the data once the buffer
 has been filled

push

  $buffer->push(@data);

  pushes data to buffer

flush

  $buffer->flush();

  passes data to callback and clears buffer

COPYRIGHT

This software is copyright (c) 2019, Anthony Lucas.

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.