diff options
| author | Nicolas Dato <nicolas.dato@gmail.com> | 2025-07-05 19:53:02 -0300 |
|---|---|---|
| committer | Nicolas Dato <nicolas.dato@gmail.com> | 2025-07-05 19:53:02 -0300 |
| commit | 37feaa48d5b7c7e1773acf364d7e28bfa46bbd78 (patch) | |
| tree | f105eb52670246987b932200afa6fd2d992e5d00 /src/tuberia.h | |
| parent | 4c15b4e3459311f8d458e0e9c031a473efe5f0b8 (diff) | |
| download | libtuberia-37feaa48d5b7c7e1773acf364d7e28bfa46bbd78.tar.gz | |
adding tube_inject_at() to inject elements at any stage, and changing tube_wait_empty() for tube_stop_and_wait_empty()
Diffstat (limited to 'src/tuberia.h')
| -rw-r--r-- | src/tuberia.h | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/tuberia.h b/src/tuberia.h index 9b3c56c..f83ea6f 100644 --- a/src/tuberia.h +++ b/src/tuberia.h @@ -23,8 +23,9 @@ int tube_stop(tube *ctx); void tube_free(tube **ctx); int tube_inject(tube *ctx, int timeout_ms, void *element); +int tube_inject_at(tube *ctx, int stage, int timeout_ms, void *element); void *tube_retrive(tube *ctx, int timeout_ms); -void tube_wait_empty(tube *ctx); +void tube_stop_and_wait_empty(tube *ctx); void tube_discard_all(tube *ctx); int tube_get_queued(const tube *ctx, int stage); |