#ifndef LIBTUBERIA_H__
#define LIBTUBERIA_H__

typedef struct tube tube;
typedef struct tube_source tube_source;
typedef struct tube_stage tube_stage;

typedef void *(*tube_fetch)(void *opaque);
typedef void *(*tube_process)(void *element, void *opaque);
typedef void (*tube_sink)(void *element, void *opaque);
typedef void (*tube_free_element)(void *element);

tube_source *tube_source_alloc(int nslots, tube_fetch fetch, void *opaque, tube_free_element free_element);
tube_stage *tube_stage_alloc(int nslots, tube_process process, void *opaque, tube_free_element free_element);
void tube_stage_free(tube_stage **stage);
void tube_source_and_stages_free(tube_source **source);

int tube_stage_append(tube_source *source, tube_stage *stage);

tube *tube_alloc(const tube_source *source, tube_sink sink, void *opaque);
int tube_start(tube *ctx);
int tube_stop(tube *ctx);
void tube_free(tube **ctx);

int tube_inject(tube *ctx, int timeout_ms, void *element);
void *tube_retrive(tube *ctx, int timeout_ms);
void tube_wait_empty(tube *ctx);
void tube_discard_all(tube *ctx);

int tube_get_queued(const tube *ctx, int stage);
int tube_get_slots(const tube *ctx, int stage);

#endif //LIBTUBERIA_H__