From 37feaa48d5b7c7e1773acf364d7e28bfa46bbd78 Mon Sep 17 00:00:00 2001 From: Nicolas Dato Date: Sat, 5 Jul 2025 19:53:02 -0300 Subject: adding tube_inject_at() to inject elements at any stage, and changing tube_wait_empty() for tube_stop_and_wait_empty() --- src/tuberia.h | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/tuberia.h') 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); -- cgit v1.2.3