From 3ccc2d5ed9b5389905032ed74f46bb22b3b061d1 Mon Sep 17 00:00:00 2001
From: Sven Slootweg <admin@cryto.net>
Date: Tue, 2 Mar 2021 12:33:24 +0100
Subject: [PATCH] Update implementation to new simple-sink API

---
 index.js | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

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