flux-stream-util

flux-stream-util —

Synopsis




gint        flux_stream_process             (gpointer source,
                                             guint block_size,
                                             guint max_size,
                                             FluxStreamProcessorFunc *processor,
                                             FluxStreamReaderFunc *reader,
                                             gpointer data);
gint        flux_stream_process_dual        (gpointer source1,
                                             gpointer source2,
                                             guint block_size,
                                             guint max_size,
                                             FluxStreamDualProcessorFunc *processor,
                                             FluxStreamReaderFunc *reader1,
                                             FluxStreamReaderFunc *reader2,
                                             gpointer data);

Description

Details

flux_stream_process ()

gint        flux_stream_process             (gpointer source,
                                             guint block_size,
                                             guint max_size,
                                             FluxStreamProcessorFunc *processor,
                                             FluxStreamReaderFunc *reader,
                                             gpointer data);

source :
block_size :
max_size :
processor :
reader :
data :
Returns :

flux_stream_process_dual ()

gint        flux_stream_process_dual        (gpointer source1,
                                             gpointer source2,
                                             guint block_size,
                                             guint max_size,
                                             FluxStreamDualProcessorFunc *processor,
                                             FluxStreamReaderFunc *reader1,
                                             FluxStreamReaderFunc *reader2,
                                             gpointer data);

source1 :
source2 :
block_size :
max_size :
processor :
reader1 :
reader2 :
data :
Returns :