Liking cljdoc? Tell your friends :D
ClojureScript only.
hatti.ona.stream
process-aggregated-data!cljs
(process-aggregated-data! agg-data-channel callback)Calls callback on aggregated data that come via messages in channel. Callback accepts two arguments: data (cljs list), and completed? (bool) If there is a parser in message, resume it after a timeout.
Calls callback on aggregated data that come via messages in channel. Callback accepts two arguments: data (cljs list), and completed? (bool) If there is a parser in message, resume it after a timeout.
read-next-chunk!cljs
(read-next-chunk! data-chunk read-count agg channel)On each step of data, increment read-count atom, and put data in a list agg. After a exponentially increasing # of steps have been processed, the aggregated data gets flushed into a channel, and parser is paused. The channel reader should resume the parser after processing the data.
On each step of data, increment read-count atom, and put data in a list agg. After a exponentially increasing # of steps have been processed, the aggregated data gets flushed into a channel, and parser is paused. The channel reader should resume the parser after processing the data.
streamingly-read-json!cljs
(streamingly-read-json! url stepfn & {:keys [oboe-headers]})Given url, a node pattern matcher, and a callback, streaming-read json.
Given url, a node pattern matcher, and a callback, streaming-read json.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close