diff --git a/index.js b/index.js
index e5cda0c..c16f220 100644
--- a/index.js
+++ b/index.js
@@ -5,9 +5,12 @@ const simpleSink = require("@ppstreams/simple-sink");
 module.exports = function collect() {
 	let results = [];
 
-	return simpleSink((value) => {
-		results.push(value);
-		
-		return results;
+	return simpleSink({
+		onResult: (value) => {
+			results.push(value);
+		},
+		onEnd: () => {
+			return results;
+		}
 	});
 };