CREATE OR REPLACE FUNCTION benchmark_get(

_stream_name varchar,
_cycles int DEFAULT 1000

) RETURNS void AS $$ BEGIN

FOR i IN 1.._cycles LOOP
  -- RAISE NOTICE '%', i;
  PERFORM * FROM get_stream_messages(_stream_name, _batch_size => 1);
END LOOP;

END; $$ LANGUAGE plpgsql VOLATILE;