First part of stream rework

1 files changed, 5 insertions, 6 deletions

diff --git a/src/reintegrate.c b/src/reintegrate.c
index 67e7b347..fcffd499 100644
--- a/src/reintegrate.c
+++ b/src/reintegrate.c
@@ -140,15 +140,14 @@ static void process_image(void *pg, int cookie)
 		reflections = find_projected_peaks(&image, image.indexed_cell,
 		                                   0, 0.1);
 
-		output_intensities(&image, image.indexed_cell, reflections,
-		                   pargs->output_mutex,
-		                   pargs->config_polar,
-		                   pargs->config_closer,
-		                   pargs->ofh);
-
 		reflist_free(reflections);
 	}
 
+	pthread_mutex_lock(pargs->output_mutex);
+	write_chunk(pargs->ofh, &image, pargs->stream_flags);
+	pthread_mutex_unlock(pargs->output_mutex);
+
+
 	free(image.data);
 	if ( image.flags != NULL ) free(image.flags);
 	hdfile_close(hdfile);