Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 2 additions & 5 deletions src/xitdb/hash_map.clj
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@
(= (into {} this) (into {} other))))

clojure.lang.Seqable
(seq [this]
(seq [_]
(map-seq rhm))

clojure.lang.IFn
Expand Down Expand Up @@ -161,7 +161,7 @@
(common/-read-from-cursor (conversion/map-write-cursor whm key)))))

clojure.lang.Seqable
(seq [this]
(seq [_]
(map-seq whm))

clojure.core.protocols/IKVReduce
Expand Down Expand Up @@ -192,6 +192,3 @@

(defn xhash-map-counted [^ReadCursor read-cursor]
(->XITDBHashMap (ReadCountedHashMap. read-cursor)))



4 changes: 2 additions & 2 deletions src/xitdb/hash_set.clj
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@
(operations/set-item-count rhs))

clojure.lang.Seqable
(seq [_]
(seq [this]
(set-seq rhs))

clojure.lang.ILookup
Expand Down Expand Up @@ -117,7 +117,7 @@
(operations/set-item-count whs))

clojure.lang.Seqable
(seq [_]
(seq [this]
(set-seq whs))

clojure.lang.ILookup
Expand Down
40 changes: 21 additions & 19 deletions src/xitdb/util/operations.clj
Original file line number Diff line number Diff line change
Expand Up @@ -197,31 +197,33 @@
;; ============================================================================

(defn map-seq
"Return a lazy seq of key-value MapEntry pairs."
"Return a lazy seq of key-value MapEntry pairs, or nil if empty."
[^ReadHashMap rhm read-from-cursor]
(let [it (.iterator rhm)]
(letfn [(step []
(lazy-seq
(when (.hasNext it)
(let [cursor (.next it)
kv (.readKeyValuePair cursor)
k (read-from-cursor (.-keyCursor kv))]
(let [v (read-from-cursor (.-valueCursor kv))]
(cons (clojure.lang.MapEntry. k v) (step)))))))]
(step))))
(when (.hasNext it)
(letfn [(step []
(lazy-seq
(when (.hasNext it)
(let [cursor (.next it)
kv (.readKeyValuePair cursor)
k (read-from-cursor (.-keyCursor kv))]
(let [v (read-from-cursor (.-valueCursor kv))]
(cons (clojure.lang.MapEntry. k v) (step)))))))]
(step)))))

(defn set-seq
"Return a lazy seq values from the set."
"Return a lazy seq values from the set, or nil if empty."
[rhm read-from-cursor]
(let [it (.iterator rhm)]
(letfn [(step []
(lazy-seq
(when (.hasNext it)
(let [cursor (.next it)
kv (.readKeyValuePair cursor)
v (read-from-cursor (.-keyCursor kv))]
(cons v (step))))))]
(step))))
(when (.hasNext it)
(letfn [(step []
(lazy-seq
(when (.hasNext it)
(let [cursor (.next it)
kv (.readKeyValuePair cursor)
v (read-from-cursor (.-keyCursor kv))]
(cons v (step))))))]
(step)))))

(defn array-seq
"Creates a lazy sequence from a ReadArrayList.
Expand Down
15 changes: 14 additions & 1 deletion test/xitdb/map_test.clj
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
(ns xitdb.map-test
(:require
[clojure.test :refer :all]
[xitdb.db :as xdb]
[xitdb.test-utils :as tu :refer [with-db]]))

(deftest map-with-complex-keys
Expand All @@ -19,4 +20,16 @@
(swap! db update :foo dissoc [2 :baz])

(is (= {:foo {[1 :bar] 31}}
(tu/materialize @db))))))
(tu/materialize @db))))))

(deftest KeysTest
(with-open [db (xdb/xit-db :memory)]
(reset! db {})
(is (= nil (keys @db)))
(is (= 0 (count (keys @db))))))

(deftest KeysTestSet
(with-open [db (xdb/xit-db :memory)]
(reset! db #{})
(is (= 0 (count (keys @db))))
(is (= nil (keys @db)))))