luciano/nippy
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Experimental: add Compressable-LZMA2 type & (replaceable) de/serializer

Browse source
This commit is contained in:
Peter Taoussanis 2013-11-06 13:06:41 +07:00
parent 7e7975910a
commit da1622f271
1 changed files with 27 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
src/taoensso/nippy.clj
View file

@ -442,6 +442,33 @@
(extend-thaw 1 [s] (->MyType (.readUTF s)))
(thaw (freeze (->MyType "Joe"))))
;;; Some useful custom types - EXPERIMENTAL
(defrecord Compressable-LZMA2 [value])
(extend-freeze Compressable-LZMA2 128 [x st]
(let [ba (freeze (:value x) {:compressor nil :legacy-mode true})
ba-len (alength ba)
compress? (> ba-len 1024)]
(.writeBoolean st compress?)
(if-not compress?
(do (.writeLong st ba-len)
(.write st ba 0 ba-len))
(let [ba* (compression/compress compression/lzma2-compressor ba)
ba*-len (alength ba*)]
(.writeLong st ba*-len)
(.write st ba* 0 ba*-len)))))
(extend-thaw 128 [st]
(let [compressed? (.readBoolean st)
ba-len (.readLong st)
ba (byte-array ba-len)]
(.read st ba 0 ba-len)
(thaw ba {:compressor (when compressed? compression/lzma2-compressor)})))
(comment (count (freeze (apply str (repeatedly 1000 rand))))
(count (freeze (->> (apply str (repeatedly 1000 rand))
(->Compressable-LZMA2)))))
;;;; Stress data
(defrecord StressRecord [data])