Add batched_sink
utility for flushing sink elements together
#574
+168
−10
batched_sink
utility for flushing sink elements together
#574