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);