input_stream.h

Go to the documentation of this file.

#pragma once
 
/* ************************************************************************** */
/*      ____    _    _____ ____     _    _   _   _____ _  _   ____  ____      */
/*     / ___|  / \  |  ___|  _ \   / \  | \ | | |_   _| || | |  _ \/ ___|     */
/*     \___ \ / _ \ | |_  | |_) | / _ \ |  \| |   | | | || |_| | | \___ \     */
/*      ___) / ___ \|  _| |  _ < / ___ \| |\  |   | | |__   _| |_| |___) |    */
/*     |____/_/   \_|_|   |_| \_/_/   \_|_| \_|   |_|    |_| |____/|____/     */
/*                                                                            */
/* ************************************************************************** */
 
#include "o2s/queue.h"
 
#include <stdbool.h> // bool
#include <stddef.h>  // size_t

typedef struct input_stream
{
    queue_t buffer; 
    bool (*accumulate)(struct input_stream* self, size_t count);
} istream_t;

#define InputStreamInit(Size, Accumulate) istream_init(Size, ((bool (*)(istream_t*, size_t))(Accumulate)))
 
istream_t istream_init(size_t buffer_size, bool (*accumulate)(istream_t*, size_t));
void      istream_close(istream_t* self);
 
bool      istream_has_at_least(const istream_t* self, size_t count);


#define istream_accumulate(Stream, Count) ((istream_t*)(Stream))->accumulate((istream_t*)Stream, Count)