From 1280cfd51daf9ed174d32f024f12d46febdd27e7 Mon Sep 17 00:00:00 2001
From: Karsten Schmidt <k@postspectacular.com>
Date: Wed, 22 Aug 2018 23:27:42 +0100
Subject: [PATCH] feat(dcons): add IReducible impl, update deps & imports

---
 packages/dcons/package.json |  5 ++--
 packages/dcons/src/index.ts | 46 +++++++++++++++++++++++++++----------
 2 files changed, 37 insertions(+), 14 deletions(-)

diff --git a/packages/dcons/package.json b/packages/dcons/package.json
index 5042024642..3b226ed38d 100644
--- a/packages/dcons/package.json
+++ b/packages/dcons/package.json
@@ -32,7 +32,8 @@
         "@thi.ng/checks": "^1.5.7",
         "@thi.ng/compare": "^0.1.6",
         "@thi.ng/equiv": "^0.1.7",
-        "@thi.ng/errors": "^0.1.6"
+        "@thi.ng/errors": "^0.1.6",
+        "@thi.ng/transducers": "^1.16.0"
     },
     "keywords": [
         "datastructure",
@@ -48,4 +49,4 @@
     "publishConfig": {
         "access": "public"
     }
-}
+}
\ No newline at end of file
diff --git a/packages/dcons/src/index.ts b/packages/dcons/src/index.ts
index dbe048b5e4..97686dbd57 100644
--- a/packages/dcons/src/index.ts
+++ b/packages/dcons/src/index.ts
@@ -1,9 +1,21 @@
-import * as api from "@thi.ng/api/api";
+import {
+    Comparator,
+    ICompare,
+    ICopy,
+    IEmpty,
+    IEquiv,
+    ILength,
+    IRelease,
+    IStack,
+    Predicate
+} from "@thi.ng/api/api";
+import { isArrayLike } from "@thi.ng/checks/is-arraylike";
 import { compare } from "@thi.ng/compare";
 import { equiv } from "@thi.ng/equiv";
 import { illegalArgs } from "@thi.ng/errors/illegal-arguments";
 import { illegalState } from "@thi.ng/errors/illegal-state";
-import { isArrayLike } from "@thi.ng/checks/is-arraylike";
+import { IReducible, ReductionFn } from "@thi.ng/transducers/api";
+import { isReduced } from "@thi.ng/transducers/reduced";
 
 export interface ConsCell<T> {
     value: T;
@@ -12,13 +24,14 @@ export interface ConsCell<T> {
 }
 
 export class DCons<T> implements
-    api.ICompare<DCons<T>>,
-    api.ICopy<DCons<T>>,
-    api.IEmpty<DCons<T>>,
-    api.IEquiv,
-    api.ILength,
-    api.IRelease,
-    api.IStack<T, DCons<T>> {
+    ICompare<DCons<T>>,
+    ICopy<DCons<T>>,
+    IEmpty<DCons<T>>,
+    IEquiv,
+    ILength,
+    IReducible<any, T>,
+    IRelease,
+    IStack<T, DCons<T>> {
 
     head: ConsCell<T>;
     tail: ConsCell<T>;
@@ -107,6 +120,15 @@ export class DCons<T> implements
         }
     }
 
+    $reduce(rfn: ReductionFn<any, T>, acc: any) {
+        let cell = this.head;
+        while (cell && !isReduced(acc)) {
+            acc = rfn(acc, cell.value);
+            cell = cell.next;
+        }
+        return acc;
+    }
+
     drop() {
         const cell = this.head;
         if (cell) {
@@ -185,7 +207,7 @@ export class DCons<T> implements
         }
     }
 
-    insertSorted(value: T, cmp?: api.Comparator<T>) {
+    insertSorted(value: T, cmp?: Comparator<T>) {
         cmp = cmp || compare;
         let cell = this.head;
         while (cell) {
@@ -207,7 +229,7 @@ export class DCons<T> implements
         }
     }
 
-    findWith(fn: api.Predicate<T>) {
+    findWith(fn: Predicate<T>) {
         let cell = this.head;
         while (cell) {
             if (fn(cell.value)) {
@@ -423,7 +445,7 @@ export class DCons<T> implements
         return res;
     }
 
-    filter(pred: api.Predicate<T>) {
+    filter(pred: Predicate<T>) {
         const res = new DCons<T>();
         let cell = this.head;
         while (cell) {