pipeline.h

Go to the documentation of this file.

 
#ifndef UEL_PIPELINE_H
#define UEL_PIPELINE_H
 
#include <stdlib.h>
 
#include "uevloop/utils/closure.h"
 
typedef struct uel_pipeline uel_pipeline_t;
struct uel_pipeline{
    uel_closure_t *closures;
    size_t count;
};
 
void uel_pipeline_init(uel_pipeline_t *pipeline, uel_closure_t *closures, size_t count);
 
void *uel_pipeline_apply(uel_pipeline_t *pipeline, void *params);
 
#define UEL_PIPELINE_DECLARE(id, ...)                                         \
    uel_closure_t id##_pipeline_closures[] = {__VA_ARGS__};                   \
    uel_pipeline_t id##_pipeline;                                             \
    uel_pipeline_init(&id##_pipeline, id##_pipeline_closures,                 \
                    sizeof(id##_pipeline_closures) / sizeof(uel_closure_t));
 
#endif /* end of include guard: UEL_PIPELINE_H */