/simpletypesystem/trunk

#ifndef __H_STREAM__

#define __H_STREAM__

#include "baseobject.h"

#include "defs.h"

#include "utils.h"

/**

 * @defgroup SStream SStream

 * @addtogroup SStream

 * @{

 * @warning unimplemented.

 * @TODO

 */

BEGIN_DECLS

#define S_STREAM(o)        ((SStream *)(o))

#define S_STREAM_CLASS(c)  ((SStreamClass *)(c))

typedef struct SStream SStream;

typedef struct SStreamClass SStreamClass;

typedef struct SStreamPrivate SStreamPrivate;

typedef sbyte * (*StreamReader)(SStream * self, size_t len);

typedef void (*StreamWriter)(SStream * self, size_t len, sbyte * data);

struct SStream {

  SObject parent;

  SStreamPrivate * priv;

};

struct SStreamClass {

  SObjectClass parent_class;

  StreamReader reader;

  StreamWriter writer;

};

/**

 * Create a new stream.

 */

SStream *

s_stream_new ();

/**

 *

 */

size_t

s_stream_get_beffered (SStream * self);

/**

 * Read from the stream.

 *

 * Reading is thread safe as only one thread can preform a read or write at a

 * time.

 *

 * @param self The Stream to read from.

 * @param len The number of items to read.

 *

 * @returns An array with the bytes.

 *

 * @warning If the requested length is not available the rest will be

 *          zeroed out in the output.

 */

sbyte *

s_stream_read (SStream * self,

               size_t len);

/**

 * Write data to a stream.

 *

 * Writing to the stream is thread safe as only one thread can perform a read

 * or a write to a stream at a time.

 *

 * @param self The stream to write to.

 * @param len The number of items to write to the stream.

 * @param data The bytes to be put in the stream.

 */

void

s_stream_write (SStream * self,

                size_t len,

                sbyte * data);

/**

 * @}

 */

END_DECLS

#endif /* __H_STREAM__ */