Set @buffer to 1 by default

.gitignore

@@ -25,5 +25,6 @@ strom-*.tar
 # Temporary files, for example, from tests.
 /tmp/
 
-.DS_Store
-test_data
+/test/examples/parcels/*.csv
+
+.DS_Store

README.md

@@ -37,7 +37,7 @@ io_gets = Strom.Source.IOGets.new()
 source = :stream |> Strom.Source.new(io_gets)
 
 function = fn string -> "Hello, #{string}!" end
-transformer = :stream |> Strom.Transformer.new(function, nil, buffer: 1)
+transformer = :stream |> Strom.Transformer.new(function)
 
 io_puts = Strom.Sink.IOPuts.new()
 sink = :stream |> Strom.Sink.new(io_puts, true)

lib/gen_mix.ex

@@ -5,7 +5,7 @@ defmodule Strom.GenMix do
 
   use GenServer
 
-  @buffer 1000
+  @buffer 1
 
   defstruct pid: nil,
             inputs: [],

lib/transformer.ex

@@ -31,7 +31,7 @@ defmodule Strom.Transformer do
 
   use GenServer
 
-  @buffer 1000
+  @buffer 1
 
   defstruct pid: nil,
             running: false,

test/examples/parcels/all_parcels_shipped.csv

@@ -1,98 +1,96 @@
-ALL_PARCELS_SHIPPED,1,2023-12-18 19:34:16.674638Z
-ALL_PARCELS_SHIPPED,2,2023-12-18 02:25:53.674638Z
-ALL_PARCELS_SHIPPED,3,2023-12-18 10:53:23.674638Z
-ALL_PARCELS_SHIPPED,4,2023-12-17 16:46:43.674638Z
-ALL_PARCELS_SHIPPED,5,2023-12-19 05:11:17.674638Z
-ALL_PARCELS_SHIPPED,6,2023-12-19 00:31:08.674638Z
-ALL_PARCELS_SHIPPED,7,2023-12-17 22:23:31.674638Z
-ALL_PARCELS_SHIPPED,8,2023-12-18 17:01:25.674638Z
-ALL_PARCELS_SHIPPED,9,2023-12-17 17:42:56.674638Z
-ALL_PARCELS_SHIPPED,10,2023-12-19 01:26:58.674638Z
-ALL_PARCELS_SHIPPED,11,2023-12-18 03:21:44.674638Z
-ALL_PARCELS_SHIPPED,12,2023-12-17 23:28:10.674638Z
-ALL_PARCELS_SHIPPED,13,2023-12-18 16:38:27.674638Z
-ALL_PARCELS_SHIPPED,14,2023-12-17 14:53:21.674638Z
-ALL_PARCELS_SHIPPED,15,2023-12-17 13:59:55.674638Z
-ALL_PARCELS_SHIPPED,16,2023-12-18 10:32:38.674638Z
-ALL_PARCELS_SHIPPED,17,2023-12-18 08:10:32.674638Z
-ALL_PARCELS_SHIPPED,18,2023-12-17 15:22:07.674638Z
-ALL_PARCELS_SHIPPED,19,2023-12-18 01:38:06.674638Z
-ALL_PARCELS_SHIPPED,20,2023-12-17 19:59:47.674638Z
-ALL_PARCELS_SHIPPED,21,2023-12-18 05:20:09.674638Z
-ALL_PARCELS_SHIPPED,22,2023-12-17 11:38:40.674638Z
-ALL_PARCELS_SHIPPED,23,2023-12-17 20:38:51.674638Z
-ALL_PARCELS_SHIPPED,24,2023-12-17 15:16:58.674638Z
-ALL_PARCELS_SHIPPED,25,2023-12-18 10:10:02.674638Z
-ALL_PARCELS_SHIPPED,26,2023-12-18 06:49:07.674638Z
-ALL_PARCELS_SHIPPED,27,2023-12-18 01:59:58.674638Z
-ALL_PARCELS_SHIPPED,28,2023-12-17 09:00:32.674638Z
-ALL_PARCELS_SHIPPED,29,2023-12-19 01:42:07.674638Z
-ALL_PARCELS_SHIPPED,30,2023-12-18 17:02:21.674638Z
-ALL_PARCELS_SHIPPED,31,2023-12-18 15:28:26.674638Z
-ALL_PARCELS_SHIPPED,32,2023-12-18 21:17:00.674638Z
-ALL_PARCELS_SHIPPED,33,2023-12-18 17:49:57.674638Z
-ALL_PARCELS_SHIPPED,34,2023-12-17 15:02:56.674638Z
-ALL_PARCELS_SHIPPED,35,2023-12-19 08:07:52.674638Z
-ALL_PARCELS_SHIPPED,36,2023-12-17 10:06:25.674638Z
-ALL_PARCELS_SHIPPED,37,2023-12-17 14:51:16.674638Z
-ALL_PARCELS_SHIPPED,38,2023-12-19 01:13:37.674638Z
-ALL_PARCELS_SHIPPED,39,2023-12-18 08:10:00.674638Z
-ALL_PARCELS_SHIPPED,40,2023-12-17 10:07:38.674638Z
-ALL_PARCELS_SHIPPED,41,2023-12-19 07:01:44.674638Z
-ALL_PARCELS_SHIPPED,42,2023-12-18 18:37:51.674638Z
-ALL_PARCELS_SHIPPED,43,2023-12-17 21:45:44.674638Z
-ALL_PARCELS_SHIPPED,44,2023-12-18 16:53:27.674638Z
-ALL_PARCELS_SHIPPED,45,2023-12-17 09:24:06.674638Z
-ALL_PARCELS_SHIPPED,46,2023-12-17 17:02:04.674638Z
-ALL_PARCELS_SHIPPED,47,2023-12-17 20:44:04.674638Z
-ALL_PARCELS_SHIPPED,48,2023-12-19 07:43:15.674638Z
-ALL_PARCELS_SHIPPED,49,2023-12-18 12:17:16.674638Z
-ALL_PARCELS_SHIPPED,50,2023-12-17 13:34:45.674638Z
-ALL_PARCELS_SHIPPED,51,2023-12-18 07:26:25.674638Z
-ALL_PARCELS_SHIPPED,52,2023-12-18 01:34:05.674638Z
-ALL_PARCELS_SHIPPED,53,2023-12-18 16:58:53.674638Z
-ALL_PARCELS_SHIPPED,54,2023-12-19 03:20:33.674638Z
-ALL_PARCELS_SHIPPED,55,2023-12-18 08:30:36.674638Z
-ALL_PARCELS_SHIPPED,56,2023-12-18 04:07:13.674638Z
-ALL_PARCELS_SHIPPED,57,2023-12-18 16:58:20.674638Z
-ALL_PARCELS_SHIPPED,58,2023-12-18 10:19:21.674638Z
-ALL_PARCELS_SHIPPED,59,2023-12-19 06:55:37.674638Z
-ALL_PARCELS_SHIPPED,60,2023-12-18 02:21:00.674638Z
-ALL_PARCELS_SHIPPED,61,2023-12-19 01:48:17.674638Z
-ALL_PARCELS_SHIPPED,62,2023-12-18 21:30:26.674638Z
-ALL_PARCELS_SHIPPED,63,2023-12-18 20:39:08.674638Z
-ALL_PARCELS_SHIPPED,64,2023-12-18 02:49:28.674638Z
-ALL_PARCELS_SHIPPED,65,2023-12-19 01:23:41.674638Z
-ALL_PARCELS_SHIPPED,66,2023-12-18 23:47:49.674638Z
-ALL_PARCELS_SHIPPED,67,2023-12-17 19:13:57.674638Z
-ALL_PARCELS_SHIPPED,68,2023-12-19 03:12:43.674638Z
-ALL_PARCELS_SHIPPED,69,2023-12-18 22:03:11.674638Z
-ALL_PARCELS_SHIPPED,70,2023-12-19 00:11:56.674638Z
-ALL_PARCELS_SHIPPED,71,2023-12-17 16:35:16.674638Z
-ALL_PARCELS_SHIPPED,72,2023-12-18 12:11:39.674638Z
-ALL_PARCELS_SHIPPED,73,2023-12-17 10:31:15.674638Z
-ALL_PARCELS_SHIPPED,74,2023-12-18 16:33:11.674638Z
-ALL_PARCELS_SHIPPED,75,2023-12-18 08:27:04.674638Z
-ALL_PARCELS_SHIPPED,76,2023-12-17 17:03:57.674638Z
-ALL_PARCELS_SHIPPED,77,2023-12-18 14:19:04.674638Z
-ALL_PARCELS_SHIPPED,78,2023-12-18 20:06:17.674638Z
-ALL_PARCELS_SHIPPED,79,2023-12-18 03:46:15.674638Z
-ALL_PARCELS_SHIPPED,80,2023-12-17 23:23:28.674638Z
-ALL_PARCELS_SHIPPED,81,2023-12-18 00:59:17.674638Z
-ALL_PARCELS_SHIPPED,83,2023-12-18 02:52:26.674638Z
-ALL_PARCELS_SHIPPED,84,2023-12-19 04:17:45.674638Z
-ALL_PARCELS_SHIPPED,85,2023-12-18 13:07:44.674638Z
-ALL_PARCELS_SHIPPED,86,2023-12-19 03:08:28.674638Z
-ALL_PARCELS_SHIPPED,87,2023-12-18 16:00:08.674638Z
-ALL_PARCELS_SHIPPED,88,2023-12-17 10:18:40.674638Z
-ALL_PARCELS_SHIPPED,89,2023-12-17 17:53:19.674638Z
-ALL_PARCELS_SHIPPED,90,2023-12-17 13:27:46.674638Z
-ALL_PARCELS_SHIPPED,91,2023-12-18 12:56:11.674638Z
-ALL_PARCELS_SHIPPED,92,2023-12-17 12:09:09.674638Z
-ALL_PARCELS_SHIPPED,94,2023-12-18 18:04:56.674638Z
-ALL_PARCELS_SHIPPED,95,2023-12-18 08:44:00.674638Z
-ALL_PARCELS_SHIPPED,96,2023-12-17 21:33:36.674638Z
-ALL_PARCELS_SHIPPED,97,2023-12-17 22:49:14.674638Z
-ALL_PARCELS_SHIPPED,98,2023-12-18 10:28:07.674638Z
-ALL_PARCELS_SHIPPED,99,2023-12-17 15:52:47.674638Z
-ALL_PARCELS_SHIPPED,100,2023-12-17 18:57:55.674638Z
+ALL_PARCELS_SHIPPED,1,2024-03-24 17:33:15.764232Z
+ALL_PARCELS_SHIPPED,2,2024-03-24 10:07:32.764232Z
+ALL_PARCELS_SHIPPED,3,2024-03-24 19:15:50.764232Z
+ALL_PARCELS_SHIPPED,4,2024-03-25 04:26:47.764232Z
+ALL_PARCELS_SHIPPED,5,2024-03-24 05:38:15.764232Z
+ALL_PARCELS_SHIPPED,6,2024-03-23 19:36:05.764232Z
+ALL_PARCELS_SHIPPED,7,2024-03-25 02:23:26.764232Z
+ALL_PARCELS_SHIPPED,8,2024-03-23 22:00:24.764232Z
+ALL_PARCELS_SHIPPED,9,2024-03-24 07:25:29.764232Z
+ALL_PARCELS_SHIPPED,10,2024-03-24 06:44:47.764232Z
+ALL_PARCELS_SHIPPED,11,2024-03-25 05:48:47.764232Z
+ALL_PARCELS_SHIPPED,12,2024-03-25 05:57:34.764232Z
+ALL_PARCELS_SHIPPED,13,2024-03-24 11:32:02.764232Z
+ALL_PARCELS_SHIPPED,14,2024-03-25 00:59:42.764232Z
+ALL_PARCELS_SHIPPED,15,2024-03-24 15:45:19.764232Z
+ALL_PARCELS_SHIPPED,16,2024-03-24 21:01:38.764232Z
+ALL_PARCELS_SHIPPED,17,2024-03-24 18:52:54.764232Z
+ALL_PARCELS_SHIPPED,18,2024-03-24 21:47:20.764232Z
+ALL_PARCELS_SHIPPED,19,2024-03-25 02:37:32.764232Z
+ALL_PARCELS_SHIPPED,20,2024-03-24 18:47:44.764232Z
+ALL_PARCELS_SHIPPED,21,2024-03-24 14:52:51.764232Z
+ALL_PARCELS_SHIPPED,22,2024-03-24 06:32:28.764232Z
+ALL_PARCELS_SHIPPED,23,2024-03-23 23:24:15.764232Z
+ALL_PARCELS_SHIPPED,24,2024-03-25 09:30:03.764232Z
+ALL_PARCELS_SHIPPED,25,2024-03-24 18:07:49.764232Z
+ALL_PARCELS_SHIPPED,26,2024-03-25 07:09:28.764232Z
+ALL_PARCELS_SHIPPED,27,2024-03-24 01:10:40.764232Z
+ALL_PARCELS_SHIPPED,28,2024-03-23 18:32:43.764232Z
+ALL_PARCELS_SHIPPED,29,2024-03-25 05:40:13.764232Z
+ALL_PARCELS_SHIPPED,30,2024-03-25 11:34:15.764232Z
+ALL_PARCELS_SHIPPED,31,2024-03-25 11:12:24.764232Z
+ALL_PARCELS_SHIPPED,32,2024-03-24 07:49:52.764232Z
+ALL_PARCELS_SHIPPED,33,2024-03-23 22:01:23.764232Z
+ALL_PARCELS_SHIPPED,34,2024-03-24 16:27:31.764232Z
+ALL_PARCELS_SHIPPED,35,2024-03-25 13:35:26.764232Z
+ALL_PARCELS_SHIPPED,36,2024-03-24 01:19:43.764232Z
+ALL_PARCELS_SHIPPED,37,2024-03-23 18:55:10.764232Z
+ALL_PARCELS_SHIPPED,38,2024-03-24 16:45:11.764232Z
+ALL_PARCELS_SHIPPED,39,2024-03-25 05:35:35.764232Z
+ALL_PARCELS_SHIPPED,40,2024-03-23 19:19:36.764232Z
+ALL_PARCELS_SHIPPED,42,2024-03-24 21:00:11.764232Z
+ALL_PARCELS_SHIPPED,43,2024-03-25 07:29:40.764232Z
+ALL_PARCELS_SHIPPED,44,2024-03-24 14:04:29.764232Z
+ALL_PARCELS_SHIPPED,45,2024-03-24 14:54:48.764232Z
+ALL_PARCELS_SHIPPED,46,2024-03-25 04:53:46.764232Z
+ALL_PARCELS_SHIPPED,47,2024-03-23 17:57:38.764232Z
+ALL_PARCELS_SHIPPED,48,2024-03-24 10:50:10.764232Z
+ALL_PARCELS_SHIPPED,49,2024-03-25 09:18:25.764232Z
+ALL_PARCELS_SHIPPED,50,2024-03-24 10:28:12.764232Z
+ALL_PARCELS_SHIPPED,51,2024-03-24 19:05:32.764232Z
+ALL_PARCELS_SHIPPED,52,2024-03-23 17:17:57.764232Z
+ALL_PARCELS_SHIPPED,53,2024-03-25 06:46:12.764232Z
+ALL_PARCELS_SHIPPED,54,2024-03-25 13:46:40.764232Z
+ALL_PARCELS_SHIPPED,55,2024-03-23 17:17:24.764232Z
+ALL_PARCELS_SHIPPED,58,2024-03-25 12:05:02.764232Z
+ALL_PARCELS_SHIPPED,59,2024-03-24 16:09:13.764232Z
+ALL_PARCELS_SHIPPED,60,2024-03-25 01:37:31.764232Z
+ALL_PARCELS_SHIPPED,61,2024-03-24 22:45:04.764232Z
+ALL_PARCELS_SHIPPED,62,2024-03-24 07:18:31.764232Z
+ALL_PARCELS_SHIPPED,63,2024-03-25 04:26:55.764232Z
+ALL_PARCELS_SHIPPED,64,2024-03-24 12:55:27.764232Z
+ALL_PARCELS_SHIPPED,65,2024-03-25 12:20:21.764232Z
+ALL_PARCELS_SHIPPED,66,2024-03-24 18:57:55.764232Z
+ALL_PARCELS_SHIPPED,67,2024-03-24 10:39:43.764232Z
+ALL_PARCELS_SHIPPED,68,2024-03-24 06:43:28.764232Z
+ALL_PARCELS_SHIPPED,69,2024-03-24 09:12:36.764232Z
+ALL_PARCELS_SHIPPED,70,2024-03-24 19:07:12.764232Z
+ALL_PARCELS_SHIPPED,72,2024-03-24 18:37:32.764232Z
+ALL_PARCELS_SHIPPED,73,2024-03-24 18:02:32.764232Z
+ALL_PARCELS_SHIPPED,74,2024-03-24 17:13:35.764232Z
+ALL_PARCELS_SHIPPED,75,2024-03-24 06:30:29.764232Z
+ALL_PARCELS_SHIPPED,76,2024-03-24 19:06:09.764232Z
+ALL_PARCELS_SHIPPED,77,2024-03-25 11:55:05.764232Z
+ALL_PARCELS_SHIPPED,78,2024-03-25 07:01:31.764232Z
+ALL_PARCELS_SHIPPED,79,2024-03-24 21:15:53.764232Z
+ALL_PARCELS_SHIPPED,80,2024-03-24 11:12:53.764232Z
+ALL_PARCELS_SHIPPED,81,2024-03-24 20:10:07.764232Z
+ALL_PARCELS_SHIPPED,82,2024-03-24 09:22:36.764232Z
+ALL_PARCELS_SHIPPED,83,2024-03-24 22:29:10.764232Z
+ALL_PARCELS_SHIPPED,84,2024-03-25 00:05:00.764232Z
+ALL_PARCELS_SHIPPED,85,2024-03-25 06:45:57.764232Z
+ALL_PARCELS_SHIPPED,86,2024-03-25 15:28:57.764232Z
+ALL_PARCELS_SHIPPED,87,2024-03-24 16:38:56.764232Z
+ALL_PARCELS_SHIPPED,88,2024-03-25 00:44:52.764232Z
+ALL_PARCELS_SHIPPED,89,2024-03-23 17:47:04.764232Z
+ALL_PARCELS_SHIPPED,90,2024-03-23 21:02:56.764232Z
+ALL_PARCELS_SHIPPED,91,2024-03-24 02:55:28.764232Z
+ALL_PARCELS_SHIPPED,92,2024-03-25 12:40:02.764232Z
+ALL_PARCELS_SHIPPED,93,2024-03-24 00:57:07.764232Z
+ALL_PARCELS_SHIPPED,94,2024-03-25 07:57:09.764232Z
+ALL_PARCELS_SHIPPED,95,2024-03-25 11:22:21.764232Z
+ALL_PARCELS_SHIPPED,96,2024-03-24 17:02:32.764232Z
+ALL_PARCELS_SHIPPED,97,2024-03-23 20:58:20.764232Z
+ALL_PARCELS_SHIPPED,98,2024-03-25 01:05:36.764232Z
+ALL_PARCELS_SHIPPED,99,2024-03-23 23:28:07.764232Z
+ALL_PARCELS_SHIPPED,100,2024-03-24 17:18:29.764232Z