diff --git a/doc/rxsci/latest/_sources/operators.rst.txt b/doc/rxsci/latest/_sources/operators.rst.txt
index b85bc9c..86dc73f 100644
--- a/doc/rxsci/latest/_sources/operators.rst.txt
+++ b/doc/rxsci/latest/_sources/operators.rst.txt
@@ -14,4 +14,5 @@ Operators
    Data <operators_data>
    IO <operators_io>   
    Framing <operators_framing>
+   Compression <operators_compression>
    State <operators_state>   
diff --git a/doc/rxsci/latest/_sources/operators_compression.rst.txt b/doc/rxsci/latest/_sources/operators_compression.rst.txt
new file mode 100644
index 0000000..7845aeb
--- /dev/null
+++ b/doc/rxsci/latest/_sources/operators_compression.rst.txt
@@ -0,0 +1,16 @@
+.. operators_framing:
+
+Compression
+=============
+
+gzip
+------
+
+.. automodule:: rxsci.compression.z
+    :members: compress, decompress
+
+zstd
+--------------
+
+.. automodule:: rxsci.compression.zstd
+    :members: compress, decopress
diff --git a/doc/rxsci/latest/genindex.html b/doc/rxsci/latest/genindex.html
index 3140340..c04866d 100644
--- a/doc/rxsci/latest/genindex.html
+++ b/doc/rxsci/latest/genindex.html
@@ -111,6 +111,12 @@ <h2 id="C">C</h2>
 </li>
       <li><a href="operators_data.html#rxsci.data.clip">clip() (in module rxsci.data)</a>
 </li>
+      <li><a href="operators_compression.html#rxsci.compression.z.compress">compress() (in module rxsci.compression.z)</a>
+
+      <ul>
+        <li><a href="operators_compression.html#rxsci.compression.zstd.compress">(in module rxsci.compression.zstd)</a>
+</li>
+      </ul></li>
   </ul></td>
   <td style="width: 33%; vertical-align: top;"><ul>
       <li><a href="operators_other.html#rxsci.ops.count">count() (in module rxsci.ops)</a>
@@ -125,6 +131,8 @@ <h2 id="C">C</h2>
 <h2 id="D">D</h2>
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%; vertical-align: top;"><ul>
+      <li><a href="operators_compression.html#rxsci.compression.z.decompress">decompress() (in module rxsci.compression.z)</a>
+</li>
       <li><a href="operators_math.html#rxsci.math.dist.describe">describe() (in module rxsci.math.dist)</a>
 </li>
       <li><a href="operators_other.html#rxsci.ops.distinct">distinct() (in module rxsci.ops)</a>
@@ -261,6 +269,10 @@ <h2 id="M">M</h2>
     module
 
       <ul>
+        <li><a href="operators_compression.html#module-rxsci.compression.z">rxsci.compression.z</a>
+</li>
+        <li><a href="operators_compression.html#module-rxsci.compression.zstd">rxsci.compression.zstd</a>
+</li>
         <li><a href="operators_container.html#module-rxsci.container.csv">rxsci.container.csv</a>
 </li>
         <li><a href="operators_container.html#module-rxsci.container.json">rxsci.container.json</a>
@@ -317,6 +329,20 @@ <h2 id="R">R</h2>
       <li><a href="operators_data.html#rxsci.data.roll">roll() (in module rxsci.data)</a>
 </li>
       <li>
+    rxsci.compression.z
+
+      <ul>
+        <li><a href="operators_compression.html#module-rxsci.compression.z">module</a>
+</li>
+      </ul></li>
+      <li>
+    rxsci.compression.zstd
+
+      <ul>
+        <li><a href="operators_compression.html#module-rxsci.compression.zstd">module</a>
+</li>
+      </ul></li>
+      <li>
     rxsci.container.csv
 
       <ul>
@@ -351,6 +377,8 @@ <h2 id="R">R</h2>
         <li><a href="operators_framing.html#module-rxsci.framing.length_prefix">module</a>
 </li>
       </ul></li>
+  </ul></td>
+  <td style="width: 33%; vertical-align: top;"><ul>
       <li>
     rxsci.framing.line
 
@@ -358,8 +386,6 @@ <h2 id="R">R</h2>
         <li><a href="operators_framing.html#module-rxsci.framing.line">module</a>
 </li>
       </ul></li>
-  </ul></td>
-  <td style="width: 33%; vertical-align: top;"><ul>
       <li>
     rxsci.io
 
diff --git a/doc/rxsci/latest/index.html b/doc/rxsci/latest/index.html
index 68a9d0c..a33aeed 100644
--- a/doc/rxsci/latest/index.html
+++ b/doc/rxsci/latest/index.html
@@ -154,6 +154,11 @@ <h1>RxSci Reference Documentation<a class="headerlink" href="#rxsci-reference-do
 <li class="toctree-l3"><a class="reference internal" href="operators_framing.html#module-rxsci.framing.length_prefix">length prefix</a></li>
 </ul>
 </li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a><ul>
+<li class="toctree-l3"><a class="reference internal" href="operators_compression.html#module-rxsci.compression.z">gzip</a></li>
+<li class="toctree-l3"><a class="reference internal" href="operators_compression.html#module-rxsci.compression.zstd">zstd</a></li>
+</ul>
+</li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a><ul>
 <li class="toctree-l3"><a class="reference internal" href="operators_state.html#rxsci.state.MemoryStore"><code class="docutils literal notranslate"><span class="pre">MemoryStore</span></code></a></li>
 <li class="toctree-l3"><a class="reference internal" href="operators_state.html#rxsci.state.with_memory_store"><code class="docutils literal notranslate"><span class="pre">with_memory_store()</span></code></a></li>
diff --git a/doc/rxsci/latest/objects.inv b/doc/rxsci/latest/objects.inv
index 8dcb446..42d37ca 100644
Binary files a/doc/rxsci/latest/objects.inv and b/doc/rxsci/latest/objects.inv differ
diff --git a/doc/rxsci/latest/operators.html b/doc/rxsci/latest/operators.html
index 93e2d7c..5314f75 100644
--- a/doc/rxsci/latest/operators.html
+++ b/doc/rxsci/latest/operators.html
@@ -54,6 +54,7 @@
 <li class="toctree-l2"><a class="reference internal" href="operators_data.html">Data</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
@@ -195,6 +196,18 @@ <h1>Operators<a class="headerlink" href="#operators" title="Link to this heading
 </li>
 </ul>
 </li>
+<li class="toctree-l1"><a class="reference internal" href="operators_compression.html">Compression</a><ul>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html#module-rxsci.compression.z">gzip</a><ul>
+<li class="toctree-l3"><a class="reference internal" href="operators_compression.html#rxsci.compression.z.compress"><code class="docutils literal notranslate"><span class="pre">compress()</span></code></a></li>
+<li class="toctree-l3"><a class="reference internal" href="operators_compression.html#rxsci.compression.z.decompress"><code class="docutils literal notranslate"><span class="pre">decompress()</span></code></a></li>
+</ul>
+</li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html#module-rxsci.compression.zstd">zstd</a><ul>
+<li class="toctree-l3"><a class="reference internal" href="operators_compression.html#rxsci.compression.zstd.compress"><code class="docutils literal notranslate"><span class="pre">compress()</span></code></a></li>
+</ul>
+</li>
+</ul>
+</li>
 <li class="toctree-l1"><a class="reference internal" href="operators_state.html">State</a><ul>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html#rxsci.state.MemoryStore"><code class="docutils literal notranslate"><span class="pre">MemoryStore</span></code></a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html#rxsci.state.with_memory_store"><code class="docutils literal notranslate"><span class="pre">with_memory_store()</span></code></a></li>
diff --git a/doc/rxsci/latest/operators_compression.html b/doc/rxsci/latest/operators_compression.html
new file mode 100644
index 0000000..22d496a
--- /dev/null
+++ b/doc/rxsci/latest/operators_compression.html
@@ -0,0 +1,167 @@
+<!DOCTYPE html>
+<html class="writer-html5" lang="en" >
+<head>
+  <meta charset="utf-8" /><meta name="generator" content="Docutils 0.18.1: http://docutils.sourceforge.net/" />
+
+  <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+  <title>Compression &mdash; rxsci 0.19.0 documentation</title>
+      <link rel="stylesheet" href="_static/pygments.css" type="text/css" />
+      <link rel="stylesheet" href="_static/css/theme.css" type="text/css" />
+  <!--[if lt IE 9]>
+    <script src="_static/js/html5shiv.min.js"></script>
+  <![endif]-->
+  
+        <script src="_static/jquery.js?v=5d32c60e"></script>
+        <script src="_static/_sphinx_javascript_frameworks_compat.js?v=2cd50e6c"></script>
+        <script src="_static/documentation_options.js?v=cbfb3150"></script>
+        <script src="_static/doctools.js?v=888ff710"></script>
+        <script src="_static/sphinx_highlight.js?v=dc90522c"></script>
+    <script src="_static/js/theme.js"></script>
+    <link rel="index" title="Index" href="genindex.html" />
+    <link rel="search" title="Search" href="search.html" />
+    <link rel="next" title="State" href="operators_state.html" />
+    <link rel="prev" title="Framing" href="operators_framing.html" /> 
+</head>
+
+<body class="wy-body-for-nav"> 
+  <div class="wy-grid-for-nav">
+    <nav data-toggle="wy-nav-shift" class="wy-nav-side">
+      <div class="wy-side-scroll">
+        <div class="wy-side-nav-search" >
+
+          
+          
+          <a href="index.html" class="icon icon-home">
+            rxsci
+          </a>
+<div role="search">
+  <form id="rtd-search-form" class="wy-form" action="search.html" method="get">
+    <input type="text" name="q" placeholder="Search docs" aria-label="Search docs" />
+    <input type="hidden" name="check_keywords" value="yes" />
+    <input type="hidden" name="area" value="default" />
+  </form>
+</div>
+        </div><div class="wy-menu wy-menu-vertical" data-spy="affix" role="navigation" aria-label="Navigation menu">
+              <p class="caption" role="heading"><span class="caption-text">Contents:</span></p>
+<ul class="current">
+<li class="toctree-l1"><a class="reference internal" href="installation.html">Installation</a></li>
+<li class="toctree-l1"><a class="reference internal" href="get_started.html">Get Started</a></li>
+<li class="toctree-l1 current"><a class="reference internal" href="operators.html">Operators</a><ul class="current">
+<li class="toctree-l2"><a class="reference internal" href="operators_other.html">Base</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_error.html">Error</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_math.html">Math</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_container.html">Container</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_data.html">Data</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2 current"><a class="current reference internal" href="#">Compression</a><ul>
+<li class="toctree-l3"><a class="reference internal" href="#module-rxsci.compression.z">gzip</a><ul>
+<li class="toctree-l4"><a class="reference internal" href="#rxsci.compression.z.compress"><code class="docutils literal notranslate"><span class="pre">compress()</span></code></a></li>
+<li class="toctree-l4"><a class="reference internal" href="#rxsci.compression.z.decompress"><code class="docutils literal notranslate"><span class="pre">decompress()</span></code></a></li>
+</ul>
+</li>
+<li class="toctree-l3"><a class="reference internal" href="#module-rxsci.compression.zstd">zstd</a><ul>
+<li class="toctree-l4"><a class="reference internal" href="#rxsci.compression.zstd.compress"><code class="docutils literal notranslate"><span class="pre">compress()</span></code></a></li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
+</ul>
+</li>
+</ul>
+
+        </div>
+      </div>
+    </nav>
+
+    <section data-toggle="wy-nav-shift" class="wy-nav-content-wrap"><nav class="wy-nav-top" aria-label="Mobile navigation menu" >
+          <i data-toggle="wy-nav-top" class="fa fa-bars"></i>
+          <a href="index.html">rxsci</a>
+      </nav>
+
+      <div class="wy-nav-content">
+        <div class="rst-content">
+          <div role="navigation" aria-label="Page navigation">
+  <ul class="wy-breadcrumbs">
+      <li><a href="index.html" class="icon icon-home" aria-label="Home"></a></li>
+          <li class="breadcrumb-item"><a href="operators.html">Operators</a></li>
+      <li class="breadcrumb-item active">Compression</li>
+      <li class="wy-breadcrumbs-aside">
+            <a href="_sources/operators_compression.rst.txt" rel="nofollow"> View page source</a>
+      </li>
+  </ul>
+  <hr/>
+</div>
+          <div role="main" class="document" itemscope="itemscope" itemtype="http://schema.org/Article">
+           <div itemprop="articleBody">
+             
+  <section id="compression">
+<h1>Compression<a class="headerlink" href="#compression" title="Link to this heading"></a></h1>
+<section id="module-rxsci.compression.z">
+<span id="gzip"></span><h2>gzip<a class="headerlink" href="#module-rxsci.compression.z" title="Link to this heading"></a></h2>
+<dl class="py function">
+<dt class="sig sig-object py" id="rxsci.compression.z.compress">
+<span class="sig-prename descclassname"><span class="pre">rxsci.compression.z.</span></span><span class="sig-name descname"><span class="pre">compress</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#rxsci.compression.z.compress" title="Link to this definition"></a></dt>
+<dd><p>Compresses an Observable of bytes with gzip-compression</p>
+<p>The incoming elements are compressed in streaming mode until the
+observable completed.</p>
+<p>The source must be an Observable.</p>
+</dd></dl>
+
+<dl class="py function">
+<dt class="sig sig-object py" id="rxsci.compression.z.decompress">
+<span class="sig-prename descclassname"><span class="pre">rxsci.compression.z.</span></span><span class="sig-name descname"><span class="pre">decompress</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#rxsci.compression.z.decompress" title="Link to this definition"></a></dt>
+<dd><p>Decompresses an Observable of bytes with gzip-compression</p>
+<p>The incoming elements are decompressed in streaming mode until the
+observable completed.</p>
+<p>The source must be an Observable.</p>
+</dd></dl>
+
+</section>
+<section id="module-rxsci.compression.zstd">
+<span id="zstd"></span><h2>zstd<a class="headerlink" href="#module-rxsci.compression.zstd" title="Link to this heading"></a></h2>
+<dl class="py function">
+<dt class="sig sig-object py" id="rxsci.compression.zstd.compress">
+<span class="sig-prename descclassname"><span class="pre">rxsci.compression.zstd.</span></span><span class="sig-name descname"><span class="pre">compress</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#rxsci.compression.zstd.compress" title="Link to this definition"></a></dt>
+<dd><p>Compresses an Observable of bytes with zstd-compression</p>
+<p>The incoming elements are compressed in streaming mode until the
+observable completed.</p>
+<p>The source must be an Observable.</p>
+</dd></dl>
+
+</section>
+</section>
+
+
+           </div>
+          </div>
+          <footer><div class="rst-footer-buttons" role="navigation" aria-label="Footer">
+        <a href="operators_framing.html" class="btn btn-neutral float-left" title="Framing" accesskey="p" rel="prev"><span class="fa fa-arrow-circle-left" aria-hidden="true"></span> Previous</a>
+        <a href="operators_state.html" class="btn btn-neutral float-right" title="State" accesskey="n" rel="next">Next <span class="fa fa-arrow-circle-right" aria-hidden="true"></span></a>
+    </div>
+
+  <hr/>
+
+  <div role="contentinfo">
+    <p>&#169; Copyright 2020, R. Picard.</p>
+  </div>
+
+  Built with <a href="https://www.sphinx-doc.org/">Sphinx</a> using a
+    <a href="https://github.com/readthedocs/sphinx_rtd_theme">theme</a>
+    provided by <a href="https://readthedocs.org">Read the Docs</a>.
+   
+
+</footer>
+        </div>
+      </div>
+    </section>
+  </div>
+  <script>
+      jQuery(function () {
+          SphinxRtdTheme.Navigation.enable(true);
+      });
+  </script> 
+
+</body>
+</html>
\ No newline at end of file
diff --git a/doc/rxsci/latest/operators_container.html b/doc/rxsci/latest/operators_container.html
index 27aed47..55b7415 100644
--- a/doc/rxsci/latest/operators_container.html
+++ b/doc/rxsci/latest/operators_container.html
@@ -71,6 +71,7 @@
 <li class="toctree-l2"><a class="reference internal" href="operators_data.html">Data</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
diff --git a/doc/rxsci/latest/operators_data.html b/doc/rxsci/latest/operators_data.html
index 81e22df..231a147 100644
--- a/doc/rxsci/latest/operators_data.html
+++ b/doc/rxsci/latest/operators_data.html
@@ -65,6 +65,7 @@
 </li>
 <li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
diff --git a/doc/rxsci/latest/operators_error.html b/doc/rxsci/latest/operators_error.html
index 7bb2675..e5551f7 100644
--- a/doc/rxsci/latest/operators_error.html
+++ b/doc/rxsci/latest/operators_error.html
@@ -59,6 +59,7 @@
 <li class="toctree-l2"><a class="reference internal" href="operators_data.html">Data</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
diff --git a/doc/rxsci/latest/operators_framing.html b/doc/rxsci/latest/operators_framing.html
index 342b2a2..42c4a49 100644
--- a/doc/rxsci/latest/operators_framing.html
+++ b/doc/rxsci/latest/operators_framing.html
@@ -19,7 +19,7 @@
     <script src="_static/js/theme.js"></script>
     <link rel="index" title="Index" href="genindex.html" />
     <link rel="search" title="Search" href="search.html" />
-    <link rel="next" title="State" href="operators_state.html" />
+    <link rel="next" title="Compression" href="operators_compression.html" />
     <link rel="prev" title="IO" href="operators_io.html" /> 
 </head>
 
@@ -66,6 +66,7 @@
 </li>
 </ul>
 </li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
@@ -139,7 +140,7 @@ <h1>Framing<a class="headerlink" href="#framing" title="Link to this heading">
           </div>
           <footer><div class="rst-footer-buttons" role="navigation" aria-label="Footer">
         <a href="operators_io.html" class="btn btn-neutral float-left" title="IO" accesskey="p" rel="prev"><span class="fa fa-arrow-circle-left" aria-hidden="true"></span> Previous</a>
-        <a href="operators_state.html" class="btn btn-neutral float-right" title="State" accesskey="n" rel="next">Next <span class="fa fa-arrow-circle-right" aria-hidden="true"></span></a>
+        <a href="operators_compression.html" class="btn btn-neutral float-right" title="Compression" accesskey="n" rel="next">Next <span class="fa fa-arrow-circle-right" aria-hidden="true"></span></a>
     </div>
 
   <hr/>
diff --git a/doc/rxsci/latest/operators_io.html b/doc/rxsci/latest/operators_io.html
index 64708ce..453922b 100644
--- a/doc/rxsci/latest/operators_io.html
+++ b/doc/rxsci/latest/operators_io.html
@@ -59,6 +59,7 @@
 </ul>
 </li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
diff --git a/doc/rxsci/latest/operators_math.html b/doc/rxsci/latest/operators_math.html
index 0ad3e0d..a5174f7 100644
--- a/doc/rxsci/latest/operators_math.html
+++ b/doc/rxsci/latest/operators_math.html
@@ -80,6 +80,7 @@
 <li class="toctree-l2"><a class="reference internal" href="operators_data.html">Data</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
diff --git a/doc/rxsci/latest/operators_other.html b/doc/rxsci/latest/operators_other.html
index 16ea888..b05c8b5 100644
--- a/doc/rxsci/latest/operators_other.html
+++ b/doc/rxsci/latest/operators_other.html
@@ -79,6 +79,7 @@
 <li class="toctree-l2"><a class="reference internal" href="operators_data.html">Data</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_state.html">State</a></li>
 </ul>
 </li>
diff --git a/doc/rxsci/latest/operators_state.html b/doc/rxsci/latest/operators_state.html
index 60a5ec8..c9b3949 100644
--- a/doc/rxsci/latest/operators_state.html
+++ b/doc/rxsci/latest/operators_state.html
@@ -19,7 +19,7 @@
     <script src="_static/js/theme.js"></script>
     <link rel="index" title="Index" href="genindex.html" />
     <link rel="search" title="Search" href="search.html" />
-    <link rel="prev" title="Framing" href="operators_framing.html" /> 
+    <link rel="prev" title="Compression" href="operators_compression.html" /> 
 </head>
 
 <body class="wy-body-for-nav"> 
@@ -53,6 +53,7 @@
 <li class="toctree-l2"><a class="reference internal" href="operators_data.html">Data</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_io.html">IO</a></li>
 <li class="toctree-l2"><a class="reference internal" href="operators_framing.html">Framing</a></li>
+<li class="toctree-l2"><a class="reference internal" href="operators_compression.html">Compression</a></li>
 <li class="toctree-l2 current"><a class="current reference internal" href="#">State</a><ul>
 <li class="toctree-l3"><a class="reference internal" href="#rxsci.state.MemoryStore"><code class="docutils literal notranslate"><span class="pre">MemoryStore</span></code></a></li>
 <li class="toctree-l3"><a class="reference internal" href="#rxsci.state.with_memory_store"><code class="docutils literal notranslate"><span class="pre">with_memory_store()</span></code></a></li>
@@ -135,7 +136,7 @@
            </div>
           </div>
           <footer><div class="rst-footer-buttons" role="navigation" aria-label="Footer">
-        <a href="operators_framing.html" class="btn btn-neutral float-left" title="Framing" accesskey="p" rel="prev"><span class="fa fa-arrow-circle-left" aria-hidden="true"></span> Previous</a>
+        <a href="operators_compression.html" class="btn btn-neutral float-left" title="Compression" accesskey="p" rel="prev"><span class="fa fa-arrow-circle-left" aria-hidden="true"></span> Previous</a>
     </div>
 
   <hr/>
diff --git a/doc/rxsci/latest/py-modindex.html b/doc/rxsci/latest/py-modindex.html
index 92a751f..53f8266 100644
--- a/doc/rxsci/latest/py-modindex.html
+++ b/doc/rxsci/latest/py-modindex.html
@@ -89,6 +89,16 @@ <h1>Python Module Index</h1>
        <td>
        <code class="xref">rxsci</code></td><td>
        <em></em></td></tr>
+     <tr class="cg-1">
+       <td></td>
+       <td>&#160;&#160;&#160;
+       <a href="operators_compression.html#module-rxsci.compression.z"><code class="xref">rxsci.compression.z</code></a></td><td>
+       <em></em></td></tr>
+     <tr class="cg-1">
+       <td></td>
+       <td>&#160;&#160;&#160;
+       <a href="operators_compression.html#module-rxsci.compression.zstd"><code class="xref">rxsci.compression.zstd</code></a></td><td>
+       <em></em></td></tr>
      <tr class="cg-1">
        <td></td>
        <td>&#160;&#160;&#160;
diff --git a/doc/rxsci/latest/searchindex.js b/doc/rxsci/latest/searchindex.js
index bf415d4..883ab85 100644
--- a/doc/rxsci/latest/searchindex.js
+++ b/doc/rxsci/latest/searchindex.js
@@ -1 +1 @@
-Search.setIndex({"docnames": ["get_started", "index", "installation", "operators", "operators_container", "operators_data", "operators_error", "operators_framing", "operators_io", "operators_math", "operators_other", "operators_state"], "filenames": ["get_started.rst", "index.rst", "installation.rst", "operators.rst", "operators_container.rst", "operators_data.rst", "operators_error.rst", "operators_framing.rst", "operators_io.rst", "operators_math.rst", "operators_other.rst", "operators_state.rst"], "titles": ["Get Started", "RxSci Reference Documentation", "Installation", "Operators", "Container", "Data", "Error Operators", "Framing", "IO", "Math", "Base Operators", "State"], "terms": {"rxsci": [0, 2, 4, 5, 6, 7, 8, 9, 10, 11], "i": [0, 4, 5, 6, 8, 9, 10, 11], "set": [0, 4, 5, 8, 9, 10], "rxpy": [0, 10], "oper": [0, 1, 5, 9, 11], "observ": [0, 4, 5, 6, 7, 8, 9, 10], "factori": [0, 4], "dedic": [0, 6], "data": [0, 1, 3, 6, 8], "scienc": [0, 1], "Being": 0, "reactiv": 0, "especi": 0, "suit": 0, "work": [0, 5], "stream": [0, 7], "time": [0, 5], "seri": 0, "howev": 0, "can": [0, 2, 4, 5, 9, 10], "also": 0, "us": [0, 4, 5, 6, 8, 9, 10, 11], "tradit": 0, "dataset": 0, "Such": 0, "ar": [0, 2, 4, 5, 6, 9, 10, 11], "process": [0, 5, 10], "bound": [0, 5], "so": 0, "possibl": 0, "both": 0, "file": [0, 4, 8], "base": [0, 1, 3, 5, 9], "thi": [0, 1, 4, 5, 6, 8, 9, 10, 11], "when": [0, 4, 5, 8, 9, 10], "machin": [0, 1], "learn": [0, 1], "model": 0, "train": 0, "deploi": 0, "exampl": [0, 5, 6, 10], "comput": [0, 9, 10, 11], "roll": [0, 1, 3, 5], "mean": [0, 1, 3, 9], "window": [0, 5], "stride": [0, 5], "three": 0, "element": [0, 5, 9, 10], "import": 0, "rx": [0, 5, 6, 10], "r": [0, 5, 6, 8, 10], "sourc": [0, 4, 5, 6, 7, 8, 9, 10, 11], "1": [0, 4, 5, 6, 9, 10], "2": [0, 5, 6, 9, 10], "3": [0, 5, 10], "4": [0, 6, 7, 10], "5": [0, 9], "6": 0, "7": 0, "from_": [0, 6, 10], "pipe": [0, 5, 6, 10], "op": [0, 6, 10], "multiplex": [0, 1, 3, 6, 10], "pipelin": [0, 5, 6, 10, 11], "math": [0, 1, 3, 10], "reduc": [0, 9, 10], "true": [0, 4, 5, 8, 10], "subscrib": [0, 10], "on_next": [0, 10], "print": [0, 10], "0": [0, 4, 6, 9, 10, 11], "reactivex": 1, "contain": [1, 3, 9, 10], "all": [1, 5, 6, 9, 10], "For": [1, 9], "an": [1, 4, 5, 6, 7, 8, 9, 10], "introduct": 1, "see": [1, 9], "maki": 1, "nage": 1, "instal": 1, "get": 1, "start": [1, 10], "assert_": [1, 3, 10], "assert_1": [1, 3, 10], "count": [1, 3, 9, 10], "distinct": [1, 3, 10], "do_act": [1, 3, 10], "filter": [1, 3, 10], "first": [1, 3, 5, 10], "flat_map": [1, 3, 10], "from_iter": [1, 3, 10], "from_panda": [1, 3, 10], "group_bi": [1, 3, 10], "ident": [1, 3, 5, 10], "last": [1, 3, 10], "map": [1, 3, 5, 6, 10], "progress": [1, 3, 10], "scan": [1, 3, 10], "starmap": [1, 3, 10], "start_with": [1, 3, 10], "take": [1, 3, 10], "tee_map": [1, 3, 10], "to_panda": [1, 3, 10], "with_latest_from": [1, 3, 10], "error": [1, 3, 4, 10], "create_error_rout": [1, 3, 6], "ignor": [1, 3, 4, 6], "max": [1, 3, 9], "min": [1, 3, 9, 10], "stddev": [1, 3, 9], "sum": [1, 3, 9], "varianc": [1, 3, 9], "distribut": [1, 3], "formal": [1, 3], "csv": [1, 3], "json": [1, 3], "cach": [1, 3, 5, 9], "clip": [1, 3, 5], "fill_non": [1, 3, 5], "lag": [1, 3, 5], "sort": [1, 3, 5], "split": [1, 3, 5], "time_split": [1, 3, 5], "to_dequ": [1, 3, 5], "io": [1, 3], "read": [1, 3, 4, 8], "walk": [1, 3, 8], "write": [1, 3, 4, 8], "frame": [1, 3, 4], "line": [1, 3, 4, 10], "length": [1, 3, 5], "prefix": [1, 3, 10], "state": [1, 3], "memorystor": [1, 3, 11], "with_memory_stor": [1, 3, 11], "with_stor": [1, 3, 11], "index": [1, 11], "modul": [1, 9], "The": [2, 4, 5, 6, 7, 8, 9, 10], "releas": 2, "publish": [2, 5], "pypi": 2, "you": 2, "pip": 2, "python3": 2, "m": 2, "describ": [3, 9], "histogram": [3, 9], "merg": [3, 9, 10], "quantil": [3, 9], "updat": [3, 9, 10], "create_line_pars": [3, 4], "dump": [3, 4], "dump_to_fil": [3, 4], "load": [3, 4], "load_from_fil": [3, 4], "unfram": [3, 7], "dtype": 4, "none_valu": 4, "separ": 4, "escapechar": 4, "ignore_error": 4, "fals": [4, 5, 9, 10], "schema_nam": 4, "x": [4, 10], "creat": [4, 5, 6, 10], "parser": 4, "paramet": [4, 5, 8, 9, 10, 11], "A": [4, 5, 6, 9, 10, 11], "list": [4, 5, 8, 9, 10], "name": [4, 10, 11], "type": [4, 5, 10], "tupl": [4, 5, 6, 9, 10, 11], "namedtupl": [4, 10], "class": [4, 10, 11], "option": [4, 5, 8, 9, 10], "valu": [4, 5, 9, 10], "consid": [4, 10], "none": [4, 5, 8, 9, 10, 11], "token": 4, "each": [4, 5, 8, 9, 10, 11], "column": [4, 10], "ani": [4, 5, 6, 10], "doe": [4, 9, 10], "match": 4, "provid": [4, 5, 9, 10], "number": [4, 5, 9, 10], "rais": [4, 5], "stop": [4, 6], "pars": 4, "skip": 4, "return": [4, 5, 6, 8, 9, 10], "function": [4, 5, 6, 9, 10], "text": [4, 7, 8], "specifi": [4, 10], "header": 4, "newlin": 4, "n": [4, 10], "must": [4, 5, 6, 7, 8, 9, 10], "indic": 4, "whether": [4, 5], "ad": [4, 9], "charact": [4, 10], "": 4, "end": [4, 10], "string": [4, 8], "item": [4, 5, 6, 7, 8, 9, 10, 11], "where": [4, 5, 6, 8, 9, 10, 11], "filenam": 4, "encod": [4, 8], "path": [4, 6, 8], "object": [4, 5, 8, 9, 10, 11], "content": [4, 8], "empti": 4, "complet": [4, 5, 9, 10], "success": 4, "while": [4, 8, 10], "parse_lin": 4, "emit": [4, 5, 6, 8, 9, 10], "one": [4, 5, 10, 11], "row": [4, 10], "per": [4, 10, 11], "e": [4, 6, 11], "g": 4, "befor": [4, 5, 9, 10], "kei": [4, 5, 10, 11], "its": [4, 11], "If": [4, 8, 9, 10], "sever": [4, 9, 10], "thei": [4, 5, 9, 10], "dict": [4, 10], "correspond": 4, "format": [4, 7], "depend": 4, "singl": [4, 9, 10], "otherwis": [4, 5, 9, 10], "messagepack": 4, "field": [5, 10], "receiv": [5, 9, 10], "save": 5, "memori": [5, 9, 11], "graph": [5, 11], "buffer": 5, "some": [5, 10], "mani": 5, "whole": [5, 8], "access": 5, "via": 5, "getattr": 5, "same": [5, 10], "than": [5, 9, 10], "lower_bound": 5, "higher_bound": 5, "between": [5, 9], "includ": 5, "muxobserv": [5, 6, 9, 10, 11], "minim": 5, "maxim": 5, "valueerror": [5, 10], "bigger": 5, "replac": 5, "size": [5, 8], "data_typ": [5, 11], "obj": [5, 11], "current": 5, "On": [5, 10], "iter": [5, 10], "project": [5, 10], "sequenc": [5, 10], "zero": 5, "more": [5, 9], "which": [5, 10], "produc": [5, 10], "inform": [5, 9], "step": [5, 10], "creation": 5, "consecut": 5, "execut": [5, 10], "neg": 5, "lambda": [5, 6, 9, 10], "accord": [5, 10], "ascend": 5, "order": [5, 11], "impement": 5, "note": 5, "them": [5, 6, 9], "It": 5, "onli": [5, 10], "batch": 5, "consum": 5, "lot": 5, "extract": [5, 10], "predic": [5, 10], "criteria": 5, "call": [5, 9, 10], "higher": 5, "time_mapp": 5, "active_timeout": 5, "inactive_timeout": 5, "closing_mapp": 5, "include_closing_item": 5, "timestamp": 5, "expir": 5, "retriv": 5, "from": [5, 7, 10], "refer": 5, "close": 5, "after": [5, 9], "durat": 5, "without": 5, "event": [5, 10], "addit": 5, "custom": 5, "loggic": 5, "implement": [5, 6, 9, 10], "In": [5, 11], "activ": 5, "inact": 5, "timeout": 5, "mapper": [5, 6, 10], "forc": [5, 10], "new": [5, 7, 10], "callabl": [5, 10], "datetim": 5, "timedelta": 5, "recept": [5, 10], "date": 5, "bool": 5, "next": 5, "extend": 5, "flatten": 5, "dequ": 5, "fifo": 5, "pop": 5, "sinc": 5, "allow": [5, 6, 10, 11], "derefer": 5, "default": 5, "behavior": 5, "append": 5, "rout": 6, "mux": [6, 11], "fatal": 6, "handler": [6, 10], "dead": 6, "letter": 6, "box": 6, "other": [6, 10], "kind": 6, "monitor": 6, "layer": 6, "still": 6, "propag": 6, "downstream": 6, "route_error": 6, "silent": 6, "drop": 6, "incom": 6, "result": [6, 9, 10], "delimit": 7, "length_prefix": 7, "prefix_s": 7, "byteord": 7, "littl": 7, "byte": 7, "len": 7, "mode": 8, "how": 8, "open": 8, "either": [8, 9], "rb": 8, "binari": 8, "chunk": 8, "ha": [8, 10], "been": [8, 9, 10], "top": 8, "recurs": 8, "directori": 8, "present": [8, 9], "sub": 8, "eeach": 8, "key_mapp": [9, 10], "maximum": 9, "averag": 9, "whose": [9, 10], "minimum": 9, "standard": 9, "deviat": 9, "approxim": 9, "real": 9, "instead": 9, "1000": 9, "less": 9, "follow": 9, "articl": 9, "standard_devi": 9, "exact_vari": 9, "algorithm": 9, "node": 9, "dist": 9, "25": 9, "75": 9, "statist": 9, "metric": 9, "distogram": 9, "ditribut": 9, "argument": [9, 10], "bin_count": 9, "100": 9, "form": [9, 10], "bin": 9, "until": 9, "enough": 9, "have": [9, 10, 11], "collect": 9, "These": 9, "typic": 9, "zip": [9, 10], "weighted_diff": 9, "appli": [9, 10], "log": 9, "weight": 9, "mai": 9, "need": [9, 11], "outlier": 9, "distrogram": 9, "exact": 9, "estim": 9, "caution": 9, "becaus": 9, "precis": 9, "usual": 9, "come": 9, "signific": 9, "impact": 9, "perform": [9, 10], "usag": [9, 10], "restrict": 9, "definit": 9, "impli": 9, "do": [9, 10], "larg": [9, 10], "ensur": 10, "evalu": 10, "on_error": 10, "firendli": 10, "displai": 10, "pair": 10, "previou": 10, "lag1": 10, "should": 10, "carefulli": 10, "due": 10, "mainten": 10, "intern": 10, "lookup": [10, 11], "structur": 10, "grow": 10, "similar": 10, "much": 10, "better": 10, "thank": 10, "meanwhil": 10, "compar": [10, 11], "hashabl": 10, "comparison": 10, "on_complet": 10, "on_creat": 10, "select": 10, "10": 10, "test": 10, "condit": 10, "satisfi": 10, "schedul": 10, "convert": 10, "accept": 10, "interv": 10, "second": 10, "progressbar": 10, "eol": 10, "python": 10, "boolean": 10, "datafram": 10, "panda": 10, "progess": 10, "nametupl": 10, "group": 10, "categori": 10, "transform": 10, "invok": 10, "done": 10, "final": 10, "de": 10, "threshold": 10, "measure_throughput": 10, "everi": 10, "associ": 10, "period": 10, "unit": 10, "accumul": 10, "seed": 10, "over": 10, "intermedi": 10, "acc": 10, "tranform": 10, "initi": 10, "deep": 10, "copi": 10, "unpack": 10, "star": 10, "posit": 10, "y": 10, "pad": 10, "prepend": 10, "preced": 10, "arg": 10, "join": 10, "chain": [10, 11], "simultan": 10, "multipl": 10, "combin": 10, "concurr": 10, "togeth": 10, "tee": 10, "combine_latest": 10, "branch": 10, "colum": 10, "infer": 10, "onc": 10, "least": 10, "obs1": 10, "default_valu": 11, "store": 11, "stateful": 11, "muxoberv": 11, "maintain": 11, "tabl": 11, "arrai": 11, "fast": 11, "hash": 11, "As": 11, "build": 11, "own": 11, "scheme": 11, "unrol": 11, "nest": 11, "k4": 11, "k3": 11, "k2": 11, "k1": 11, "k0": 11, "help": 11, "manag": 11, "topmost": 11, "level": 11}, "objects": {"rxsci.container": [[4, 0, 0, "-", "csv"], [4, 0, 0, "-", "json"]], "rxsci.container.csv": [[4, 1, 1, "", "create_line_parser"], [4, 1, 1, "", "dump"], [4, 1, 1, "", "dump_to_file"], [4, 1, 1, "", "load"], [4, 1, 1, "", "load_from_file"]], "rxsci.container.json": [[4, 1, 1, "", "dump"], [4, 1, 1, "", "dump_to_file"], [4, 1, 1, "", "load"], [4, 1, 1, "", "load_from_file"]], "rxsci": [[5, 0, 0, "-", "data"], [6, 0, 0, "-", "error"], [8, 0, 0, "-", "io"], [9, 0, 0, "-", "math"], [10, 0, 0, "-", "ops"], [11, 0, 0, "-", "state"]], "rxsci.data": [[5, 1, 1, "", "cache"], [5, 1, 1, "", "clip"], [5, 1, 1, "", "fill_none"], [5, 1, 1, "", "lag"], [5, 1, 1, "", "roll"], [5, 1, 1, "", "sort"], [5, 1, 1, "", "split"], [5, 1, 1, "", "time_split"], [5, 1, 1, "", "to_deque"]], "rxsci.error": [[6, 1, 1, "", "create_error_router"], [6, 1, 1, "", "ignore"], [6, 1, 1, "", "map"]], "rxsci.framing": [[7, 0, 0, "-", "length_prefix"], [7, 0, 0, "-", "line"]], "rxsci.framing.length_prefix": [[7, 1, 1, "", "frame"], [7, 1, 1, "", "unframe"]], "rxsci.framing.line": [[7, 1, 1, "", "frame"], [7, 1, 1, "", "unframe"]], "rxsci.io": [[8, 1, 1, "", "read"], [8, 1, 1, "", "walk"], [8, 1, 1, "", "write"]], "rxsci.math": [[9, 0, 0, "-", "dist"], [9, 0, 0, "-", "formal"], [9, 1, 1, "", "max"], [9, 1, 1, "", "mean"], [9, 1, 1, "", "min"], [9, 1, 1, "", "stddev"], [9, 1, 1, "", "sum"], [9, 1, 1, "", "variance"]], "rxsci.math.dist": [[9, 1, 1, "", "describe"], [9, 1, 1, "", "histogram"], [9, 1, 1, "", "max"], [9, 1, 1, "", "mean"], [9, 1, 1, "", "merge"], [9, 1, 1, "", "min"], [9, 1, 1, "", "quantile"], [9, 1, 1, "", "stddev"], [9, 1, 1, "", "update"], [9, 1, 1, "", "variance"]], "rxsci.math.formal": [[9, 1, 1, "", "stddev"], [9, 1, 1, "", "variance"]], "rxsci.ops": [[10, 1, 1, "", "assert_"], [10, 1, 1, "", "assert_1"], [10, 1, 1, "", "count"], [10, 1, 1, "", "distinct"], [10, 1, 1, "", "do_action"], [10, 1, 1, "", "filter"], [10, 1, 1, "", "first"], [10, 1, 1, "", "flat_map"], [10, 1, 1, "", "from_iterable"], [10, 1, 1, "", "from_pandas"], [10, 1, 1, "", "group_by"], [10, 1, 1, "", "identity"], [10, 1, 1, "", "last"], [10, 1, 1, "", "map"], [10, 1, 1, "", "multiplex"], [10, 1, 1, "", "progress"], [10, 1, 1, "", "scan"], [10, 1, 1, "", "starmap"], [10, 1, 1, "", "start_with"], [10, 1, 1, "", "take"], [10, 1, 1, "", "tee_map"], [10, 1, 1, "", "to_pandas"], [10, 1, 1, "", "with_latest_from"]], "rxsci.state": [[11, 2, 1, "", "MemoryStore"], [11, 1, 1, "", "with_memory_store"], [11, 1, 1, "", "with_store"]]}, "objtypes": {"0": "py:module", "1": "py:function", "2": "py:class"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "function", "Python function"], "2": ["py", "class", "Python class"]}, "titleterms": {"get": 0, "start": 0, "rxsci": 1, "refer": 1, "document": 1, "content": 1, "indic": 1, "tabl": 1, "instal": 2, "oper": [3, 6, 10], "contain": 4, "csv": 4, "json": 4, "data": 5, "error": 6, "frame": 7, "line": 7, "length": 7, "prefix": 7, "io": 8, "math": 9, "distribut": 9, "formal": 9, "base": 10, "state": 11}, "envversion": {"sphinx.domains.c": 3, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 9, "sphinx.domains.index": 1, "sphinx.domains.javascript": 3, "sphinx.domains.math": 2, "sphinx.domains.python": 4, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx": 60}, "alltitles": {"Get Started": [[0, "get-started"]], "RxSci Reference Documentation": [[1, "rxsci-reference-documentation"]], "Contents:": [[1, null]], "Indices and tables": [[1, "indices-and-tables"]], "Installation": [[2, "installation"]], "Operators": [[3, "operators"]], "Container": [[4, "container"]], "csv": [[4, "module-rxsci.container.csv"]], "json": [[4, "module-rxsci.container.json"]], "Data": [[5, "module-rxsci.data"]], "Error Operators": [[6, "module-rxsci.error"]], "Framing": [[7, "framing"]], "line": [[7, "module-rxsci.framing.line"]], "length prefix": [[7, "module-rxsci.framing.length_prefix"]], "IO": [[8, "module-rxsci.io"]], "Math": [[9, "module-rxsci.math"]], "Distributed": [[9, "distributed"]], "Formal": [[9, "formal"]], "Base Operators": [[10, "module-rxsci.ops"]], "State": [[11, "module-rxsci.state"]]}, "indexentries": {"create_line_parser() (in module rxsci.container.csv)": [[4, "rxsci.container.csv.create_line_parser"]], "dump() (in module rxsci.container.csv)": [[4, "rxsci.container.csv.dump"]], "dump() (in module rxsci.container.json)": [[4, "rxsci.container.json.dump"]], "dump_to_file() (in module rxsci.container.csv)": [[4, "rxsci.container.csv.dump_to_file"]], "dump_to_file() (in module rxsci.container.json)": [[4, "rxsci.container.json.dump_to_file"]], "load() (in module rxsci.container.csv)": [[4, "rxsci.container.csv.load"]], "load() (in module rxsci.container.json)": [[4, "rxsci.container.json.load"]], "load_from_file() (in module rxsci.container.csv)": [[4, "rxsci.container.csv.load_from_file"]], "load_from_file() (in module rxsci.container.json)": [[4, "rxsci.container.json.load_from_file"]], "module": [[4, "module-rxsci.container.csv"], [4, "module-rxsci.container.json"], [5, "module-rxsci.data"], [6, "module-rxsci.error"], [7, "module-rxsci.framing.length_prefix"], [7, "module-rxsci.framing.line"], [8, "module-rxsci.io"], [9, "module-rxsci.math"], [9, "module-rxsci.math.dist"], [9, "module-rxsci.math.formal"], [10, "module-rxsci.ops"], [11, "module-rxsci.state"]], "rxsci.container.csv": [[4, "module-rxsci.container.csv"]], "rxsci.container.json": [[4, "module-rxsci.container.json"]], "cache() (in module rxsci.data)": [[5, "rxsci.data.cache"]], "clip() (in module rxsci.data)": [[5, "rxsci.data.clip"]], "fill_none() (in module rxsci.data)": [[5, "rxsci.data.fill_none"]], "lag() (in module rxsci.data)": [[5, "rxsci.data.lag"]], "roll() (in module rxsci.data)": [[5, "rxsci.data.roll"]], "rxsci.data": [[5, "module-rxsci.data"]], "sort() (in module rxsci.data)": [[5, "rxsci.data.sort"]], "split() (in module rxsci.data)": [[5, "rxsci.data.split"]], "time_split() (in module rxsci.data)": [[5, "rxsci.data.time_split"]], "to_deque() (in module rxsci.data)": [[5, "rxsci.data.to_deque"]], "create_error_router() (in module rxsci.error)": [[6, "rxsci.error.create_error_router"]], "ignore() (in module rxsci.error)": [[6, "rxsci.error.ignore"]], "map() (in module rxsci.error)": [[6, "rxsci.error.map"]], "rxsci.error": [[6, "module-rxsci.error"]], "frame() (in module rxsci.framing.length_prefix)": [[7, "rxsci.framing.length_prefix.frame"]], "frame() (in module rxsci.framing.line)": [[7, "rxsci.framing.line.frame"]], "rxsci.framing.length_prefix": [[7, "module-rxsci.framing.length_prefix"]], "rxsci.framing.line": [[7, "module-rxsci.framing.line"]], "unframe() (in module rxsci.framing.length_prefix)": [[7, "rxsci.framing.length_prefix.unframe"]], "unframe() (in module rxsci.framing.line)": [[7, "rxsci.framing.line.unframe"]], "read() (in module rxsci.io)": [[8, "rxsci.io.read"]], "rxsci.io": [[8, "module-rxsci.io"]], "walk() (in module rxsci.io)": [[8, "rxsci.io.walk"]], "write() (in module rxsci.io)": [[8, "rxsci.io.write"]], "describe() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.describe"]], "histogram() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.histogram"]], "max() (in module rxsci.math)": [[9, "rxsci.math.max"]], "max() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.max"]], "mean() (in module rxsci.math)": [[9, "rxsci.math.mean"]], "mean() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.mean"]], "merge() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.merge"]], "min() (in module rxsci.math)": [[9, "rxsci.math.min"]], "min() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.min"]], "quantile() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.quantile"]], "rxsci.math": [[9, "module-rxsci.math"]], "rxsci.math.dist": [[9, "module-rxsci.math.dist"]], "rxsci.math.formal": [[9, "module-rxsci.math.formal"]], "stddev() (in module rxsci.math)": [[9, "rxsci.math.stddev"]], "stddev() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.stddev"]], "stddev() (in module rxsci.math.formal)": [[9, "rxsci.math.formal.stddev"]], "sum() (in module rxsci.math)": [[9, "rxsci.math.sum"]], "update() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.update"]], "variance() (in module rxsci.math)": [[9, "rxsci.math.variance"]], "variance() (in module rxsci.math.dist)": [[9, "rxsci.math.dist.variance"]], "variance() (in module rxsci.math.formal)": [[9, "rxsci.math.formal.variance"]], "assert_() (in module rxsci.ops)": [[10, "rxsci.ops.assert_"]], "assert_1() (in module rxsci.ops)": [[10, "rxsci.ops.assert_1"]], "count() (in module rxsci.ops)": [[10, "rxsci.ops.count"]], "distinct() (in module rxsci.ops)": [[10, "rxsci.ops.distinct"]], "do_action() (in module rxsci.ops)": [[10, "rxsci.ops.do_action"]], "filter() (in module rxsci.ops)": [[10, "rxsci.ops.filter"]], "first() (in module rxsci.ops)": [[10, "rxsci.ops.first"]], "flat_map() (in module rxsci.ops)": [[10, "rxsci.ops.flat_map"]], "from_iterable() (in module rxsci.ops)": [[10, "rxsci.ops.from_iterable"]], "from_pandas() (in module rxsci.ops)": [[10, "rxsci.ops.from_pandas"]], "group_by() (in module rxsci.ops)": [[10, "rxsci.ops.group_by"]], "identity() (in module rxsci.ops)": [[10, "rxsci.ops.identity"]], "last() (in module rxsci.ops)": [[10, "rxsci.ops.last"]], "map() (in module rxsci.ops)": [[10, "rxsci.ops.map"]], "multiplex() (in module rxsci.ops)": [[10, "rxsci.ops.multiplex"]], "progress() (in module rxsci.ops)": [[10, "rxsci.ops.progress"]], "rxsci.ops": [[10, "module-rxsci.ops"]], "scan() (in module rxsci.ops)": [[10, "rxsci.ops.scan"]], "starmap() (in module rxsci.ops)": [[10, "rxsci.ops.starmap"]], "start_with() (in module rxsci.ops)": [[10, "rxsci.ops.start_with"]], "take() (in module rxsci.ops)": [[10, "rxsci.ops.take"]], "tee_map() (in module rxsci.ops)": [[10, "rxsci.ops.tee_map"]], "to_pandas() (in module rxsci.ops)": [[10, "rxsci.ops.to_pandas"]], "with_latest_from() (in module rxsci.ops)": [[10, "rxsci.ops.with_latest_from"]], "memorystore (class in rxsci.state)": [[11, "rxsci.state.MemoryStore"]], "rxsci.state": [[11, "module-rxsci.state"]], "with_memory_store() (in module rxsci.state)": [[11, "rxsci.state.with_memory_store"]], "with_store() (in module rxsci.state)": [[11, "rxsci.state.with_store"]]}})
\ No newline at end of file
+Search.setIndex({"docnames": ["get_started", "index", "installation", "operators", "operators_compression", "operators_container", "operators_data", "operators_error", "operators_framing", "operators_io", "operators_math", "operators_other", "operators_state"], "filenames": ["get_started.rst", "index.rst", "installation.rst", "operators.rst", "operators_compression.rst", "operators_container.rst", "operators_data.rst", "operators_error.rst", "operators_framing.rst", "operators_io.rst", "operators_math.rst", "operators_other.rst", "operators_state.rst"], "titles": ["Get Started", "RxSci Reference Documentation", "Installation", "Operators", "Compression", "Container", "Data", "Error Operators", "Framing", "IO", "Math", "Base Operators", "State"], "terms": {"rxsci": [0, 2, 4, 5, 6, 7, 8, 9, 10, 11, 12], "i": [0, 5, 6, 7, 9, 10, 11, 12], "set": [0, 5, 6, 9, 10, 11], "rxpy": [0, 11], "oper": [0, 1, 6, 10, 12], "observ": [0, 4, 5, 6, 7, 8, 9, 10, 11], "factori": [0, 5], "dedic": [0, 7], "data": [0, 1, 3, 7, 9], "scienc": [0, 1], "Being": 0, "reactiv": 0, "especi": 0, "suit": 0, "work": [0, 6], "stream": [0, 4, 8], "time": [0, 6], "seri": 0, "howev": 0, "can": [0, 2, 5, 6, 10, 11], "also": 0, "us": [0, 5, 6, 7, 9, 10, 11, 12], "tradit": 0, "dataset": 0, "Such": 0, "ar": [0, 2, 4, 5, 6, 7, 10, 11, 12], "process": [0, 6, 11], "bound": [0, 6], "so": 0, "possibl": 0, "both": 0, "file": [0, 5, 9], "base": [0, 1, 3, 6, 10], "thi": [0, 1, 5, 6, 7, 9, 10, 11, 12], "when": [0, 5, 6, 9, 10, 11], "machin": [0, 1], "learn": [0, 1], "model": 0, "train": 0, "deploi": 0, "exampl": [0, 6, 7, 11], "comput": [0, 10, 11, 12], "roll": [0, 1, 3, 6], "mean": [0, 1, 3, 10], "window": [0, 6], "stride": [0, 6], "three": 0, "element": [0, 4, 6, 10, 11], "import": 0, "rx": [0, 6, 7, 11], "r": [0, 6, 7, 9, 11], "sourc": [0, 4, 5, 6, 7, 8, 9, 10, 11, 12], "1": [0, 5, 6, 7, 10, 11], "2": [0, 6, 7, 10, 11], "3": [0, 6, 11], "4": [0, 7, 8, 11], "5": [0, 10], "6": 0, "7": 0, "from_": [0, 7, 11], "pipe": [0, 6, 7, 11], "op": [0, 7, 11], "multiplex": [0, 1, 3, 7, 11], "pipelin": [0, 6, 7, 11, 12], "math": [0, 1, 3, 11], "reduc": [0, 10, 11], "true": [0, 5, 6, 9, 11], "subscrib": [0, 11], "on_next": [0, 11], "print": [0, 11], "0": [0, 5, 7, 10, 11, 12], "reactivex": 1, "contain": [1, 3, 10, 11], "all": [1, 6, 7, 10, 11], "For": [1, 10], "an": [1, 4, 5, 6, 7, 8, 9, 10, 11], "introduct": 1, "see": [1, 10], "maki": 1, "nage": 1, "instal": 1, "get": 1, "start": [1, 11], "assert_": [1, 3, 11], "assert_1": [1, 3, 11], "count": [1, 3, 10, 11], "distinct": [1, 3, 11], "do_act": [1, 3, 11], "filter": [1, 3, 11], "first": [1, 3, 6, 11], "flat_map": [1, 3, 11], "from_iter": [1, 3, 11], "from_panda": [1, 3, 11], "group_bi": [1, 3, 11], "ident": [1, 3, 6, 11], "last": [1, 3, 11], "map": [1, 3, 6, 7, 11], "progress": [1, 3, 11], "scan": [1, 3, 11], "starmap": [1, 3, 11], "start_with": [1, 3, 11], "take": [1, 3, 11], "tee_map": [1, 3, 11], "to_panda": [1, 3, 11], "with_latest_from": [1, 3, 11], "error": [1, 3, 5, 11], "create_error_rout": [1, 3, 7], "ignor": [1, 3, 5, 7], "max": [1, 3, 10], "min": [1, 3, 10, 11], "stddev": [1, 3, 10], "sum": [1, 3, 10], "varianc": [1, 3, 10], "distribut": [1, 3], "formal": [1, 3], "csv": [1, 3], "json": [1, 3], "cach": [1, 3, 6, 10], "clip": [1, 3, 6], "fill_non": [1, 3, 6], "lag": [1, 3, 6], "sort": [1, 3, 6], "split": [1, 3, 6], "time_split": [1, 3, 6], "to_dequ": [1, 3, 6], "io": [1, 3], "read": [1, 3, 5, 9], "walk": [1, 3, 9], "write": [1, 3, 5, 9], "frame": [1, 3, 5], "line": [1, 3, 5, 11], "length": [1, 3, 6], "prefix": [1, 3, 11], "compress": [1, 3], "gzip": [1, 3], "zstd": [1, 3], "state": [1, 3], "memorystor": [1, 3, 12], "with_memory_stor": [1, 3, 12], "with_stor": [1, 3, 12], "index": [1, 12], "modul": [1, 10], "The": [2, 4, 5, 6, 7, 8, 9, 10, 11], "releas": 2, "publish": [2, 6], "pypi": 2, "you": 2, "pip": 2, "python3": 2, "m": 2, "describ": [3, 10], "histogram": [3, 10], "merg": [3, 10, 11], "quantil": [3, 10], "updat": [3, 10, 11], "create_line_pars": [3, 5], "dump": [3, 5], "dump_to_fil": [3, 5], "load": [3, 5], "load_from_fil": [3, 5], "unfram": [3, 8], "decompress": [3, 4], "z": 4, "byte": [4, 8], "incom": [4, 7], "mode": [4, 9], "until": [4, 10], "complet": [4, 5, 6, 10, 11], "must": [4, 5, 6, 7, 8, 9, 10, 11], "dtype": 5, "none_valu": 5, "separ": 5, "escapechar": 5, "ignore_error": 5, "fals": [5, 6, 10, 11], "schema_nam": 5, "x": [5, 11], "creat": [5, 6, 7, 11], "parser": 5, "paramet": [5, 6, 9, 10, 11, 12], "A": [5, 6, 7, 10, 11, 12], "list": [5, 6, 9, 10, 11], "name": [5, 11, 12], "type": [5, 6, 11], "tupl": [5, 6, 7, 10, 11, 12], "namedtupl": [5, 11], "class": [5, 11, 12], "option": [5, 6, 9, 10, 11], "valu": [5, 6, 10, 11], "consid": [5, 11], "none": [5, 6, 9, 10, 11, 12], "token": 5, "each": [5, 6, 9, 10, 11, 12], "column": [5, 11], "ani": [5, 6, 7, 11], "doe": [5, 10, 11], "match": 5, "provid": [5, 6, 10, 11], "number": [5, 6, 10, 11], "rais": [5, 6], "stop": [5, 7], "pars": 5, "skip": 5, "return": [5, 6, 7, 9, 10, 11], "function": [5, 6, 7, 10, 11], "text": [5, 8, 9], "specifi": [5, 11], "header": 5, "newlin": 5, "n": [5, 11], "indic": 5, "whether": [5, 6], "ad": [5, 10], "charact": [5, 11], "": 5, "end": [5, 11], "string": [5, 9], "item": [5, 6, 7, 8, 9, 10, 11, 12], "where": [5, 6, 7, 9, 10, 11, 12], "filenam": 5, "encod": [5, 9], "path": [5, 7, 9], "object": [5, 6, 9, 10, 11, 12], "content": [5, 9], "empti": 5, "success": 5, "while": [5, 9, 11], "parse_lin": 5, "emit": [5, 6, 7, 9, 10, 11], "one": [5, 6, 11, 12], "row": [5, 11], "per": [5, 11, 12], "e": [5, 7, 12], "g": 5, "befor": [5, 6, 10, 11], "kei": [5, 6, 11, 12], "its": [5, 12], "If": [5, 9, 10, 11], "sever": [5, 10, 11], "thei": [5, 6, 10, 11], "dict": [5, 11], "correspond": 5, "format": [5, 8], "depend": 5, "singl": [5, 10, 11], "otherwis": [5, 6, 10, 11], "messagepack": 5, "field": [6, 11], "receiv": [6, 10, 11], "save": 6, "memori": [6, 10, 12], "graph": [6, 12], "buffer": 6, "some": [6, 11], "mani": 6, "whole": [6, 9], "access": 6, "via": 6, "getattr": 6, "same": [6, 11], "than": [6, 10, 11], "lower_bound": 6, "higher_bound": 6, "between": [6, 10], "includ": 6, "muxobserv": [6, 7, 10, 11, 12], "minim": 6, "maxim": 6, "valueerror": [6, 11], "bigger": 6, "replac": 6, "size": [6, 9], "data_typ": [6, 12], "obj": [6, 12], "current": 6, "On": [6, 11], "iter": [6, 11], "project": [6, 11], "sequenc": [6, 11], "zero": 6, "more": [6, 10], "which": [6, 11], "produc": [6, 11], "inform": [6, 10], "step": [6, 11], "creation": 6, "consecut": 6, "execut": [6, 11], "neg": 6, "lambda": [6, 7, 10, 11], "accord": [6, 11], "ascend": 6, "order": [6, 12], "impement": 6, "note": 6, "them": [6, 7, 10], "It": 6, "onli": [6, 11], "batch": 6, "consum": 6, "lot": 6, "extract": [6, 11], "predic": [6, 11], "criteria": 6, "call": [6, 10, 11], "higher": 6, "time_mapp": 6, "active_timeout": 6, "inactive_timeout": 6, "closing_mapp": 6, "include_closing_item": 6, "timestamp": 6, "expir": 6, "retriv": 6, "from": [6, 8, 11], "refer": 6, "close": 6, "after": [6, 10], "durat": 6, "without": 6, "event": [6, 11], "addit": 6, "custom": 6, "loggic": 6, "implement": [6, 7, 10, 11], "In": [6, 12], "activ": 6, "inact": 6, "timeout": 6, "mapper": [6, 7, 11], "forc": [6, 11], "new": [6, 8, 11], "callabl": [6, 11], "datetim": 6, "timedelta": 6, "recept": [6, 11], "date": 6, "bool": 6, "next": 6, "extend": 6, "flatten": 6, "dequ": 6, "fifo": 6, "pop": 6, "sinc": 6, "allow": [6, 7, 11, 12], "derefer": 6, "default": 6, "behavior": 6, "append": 6, "rout": 7, "mux": [7, 12], "fatal": 7, "handler": [7, 11], "dead": 7, "letter": 7, "box": 7, "other": [7, 11], "kind": 7, "monitor": 7, "layer": 7, "still": 7, "propag": 7, "downstream": 7, "route_error": 7, "silent": 7, "drop": 7, "result": [7, 10, 11], "delimit": 8, "length_prefix": 8, "prefix_s": 8, "byteord": 8, "littl": 8, "len": 8, "how": 9, "open": 9, "either": [9, 10], "rb": 9, "binari": 9, "chunk": 9, "ha": [9, 11], "been": [9, 10, 11], "top": 9, "recurs": 9, "directori": 9, "present": [9, 10], "sub": 9, "eeach": 9, "key_mapp": [10, 11], "maximum": 10, "averag": 10, "whose": [10, 11], "minimum": 10, "standard": 10, "deviat": 10, "approxim": 10, "real": 10, "instead": 10, "1000": 10, "less": 10, "follow": 10, "articl": 10, "standard_devi": 10, "exact_vari": 10, "algorithm": 10, "node": 10, "dist": 10, "25": 10, "75": 10, "statist": 10, "metric": 10, "distogram": 10, "ditribut": 10, "argument": [10, 11], "bin_count": 10, "100": 10, "form": [10, 11], "bin": 10, "enough": 10, "have": [10, 11, 12], "collect": 10, "These": 10, "typic": 10, "zip": [10, 11], "weighted_diff": 10, "appli": [10, 11], "log": 10, "weight": 10, "mai": 10, "need": [10, 12], "outlier": 10, "distrogram": 10, "exact": 10, "estim": 10, "caution": 10, "becaus": 10, "precis": 10, "usual": 10, "come": 10, "signific": 10, "impact": 10, "perform": [10, 11], "usag": [10, 11], "restrict": 10, "definit": 10, "impli": 10, "do": [10, 11], "larg": [10, 11], "ensur": 11, "evalu": 11, "on_error": 11, "firendli": 11, "displai": 11, "pair": 11, "previou": 11, "lag1": 11, "should": 11, "carefulli": 11, "due": 11, "mainten": 11, "intern": 11, "lookup": [11, 12], "structur": 11, "grow": 11, "similar": 11, "much": 11, "better": 11, "thank": 11, "meanwhil": 11, "compar": [11, 12], "hashabl": 11, "comparison": 11, "on_complet": 11, "on_creat": 11, "select": 11, "10": 11, "test": 11, "condit": 11, "satisfi": 11, "schedul": 11, "convert": 11, "accept": 11, "interv": 11, "second": 11, "progressbar": 11, "eol": 11, "python": 11, "boolean": 11, "datafram": 11, "panda": 11, "progess": 11, "nametupl": 11, "group": 11, "categori": 11, "transform": 11, "invok": 11, "done": 11, "final": 11, "de": 11, "threshold": 11, "measure_throughput": 11, "everi": 11, "associ": 11, "period": 11, "unit": 11, "accumul": 11, "seed": 11, "over": 11, "intermedi": 11, "acc": 11, "tranform": 11, "initi": 11, "deep": 11, "copi": 11, "unpack": 11, "star": 11, "posit": 11, "y": 11, "pad": 11, "prepend": 11, "preced": 11, "arg": 11, "join": 11, "chain": [11, 12], "simultan": 11, "multipl": 11, "combin": 11, "concurr": 11, "togeth": 11, "tee": 11, "combine_latest": 11, "branch": 11, "colum": 11, "infer": 11, "onc": 11, "least": 11, "obs1": 11, "default_valu": 12, "store": 12, "stateful": 12, "muxoberv": 12, "maintain": 12, "tabl": 12, "arrai": 12, "fast": 12, "hash": 12, "As": 12, "build": 12, "own": 12, "scheme": 12, "unrol": 12, "nest": 12, "k4": 12, "k3": 12, "k2": 12, "k1": 12, "k0": 12, "help": 12, "manag": 12, "topmost": 12, "level": 12}, "objects": {"rxsci.compression": [[4, 0, 0, "-", "z"], [4, 0, 0, "-", "zstd"]], "rxsci.compression.z": [[4, 1, 1, "", "compress"], [4, 1, 1, "", "decompress"]], "rxsci.compression.zstd": [[4, 1, 1, "", "compress"]], "rxsci.container": [[5, 0, 0, "-", "csv"], [5, 0, 0, "-", "json"]], "rxsci.container.csv": [[5, 1, 1, "", "create_line_parser"], [5, 1, 1, "", "dump"], [5, 1, 1, "", "dump_to_file"], [5, 1, 1, "", "load"], [5, 1, 1, "", "load_from_file"]], "rxsci.container.json": [[5, 1, 1, "", "dump"], [5, 1, 1, "", "dump_to_file"], [5, 1, 1, "", "load"], [5, 1, 1, "", "load_from_file"]], "rxsci": [[6, 0, 0, "-", "data"], [7, 0, 0, "-", "error"], [9, 0, 0, "-", "io"], [10, 0, 0, "-", "math"], [11, 0, 0, "-", "ops"], [12, 0, 0, "-", "state"]], "rxsci.data": [[6, 1, 1, "", "cache"], [6, 1, 1, "", "clip"], [6, 1, 1, "", "fill_none"], [6, 1, 1, "", "lag"], [6, 1, 1, "", "roll"], [6, 1, 1, "", "sort"], [6, 1, 1, "", "split"], [6, 1, 1, "", "time_split"], [6, 1, 1, "", "to_deque"]], "rxsci.error": [[7, 1, 1, "", "create_error_router"], [7, 1, 1, "", "ignore"], [7, 1, 1, "", "map"]], "rxsci.framing": [[8, 0, 0, "-", "length_prefix"], [8, 0, 0, "-", "line"]], "rxsci.framing.length_prefix": [[8, 1, 1, "", "frame"], [8, 1, 1, "", "unframe"]], "rxsci.framing.line": [[8, 1, 1, "", "frame"], [8, 1, 1, "", "unframe"]], "rxsci.io": [[9, 1, 1, "", "read"], [9, 1, 1, "", "walk"], [9, 1, 1, "", "write"]], "rxsci.math": [[10, 0, 0, "-", "dist"], [10, 0, 0, "-", "formal"], [10, 1, 1, "", "max"], [10, 1, 1, "", "mean"], [10, 1, 1, "", "min"], [10, 1, 1, "", "stddev"], [10, 1, 1, "", "sum"], [10, 1, 1, "", "variance"]], "rxsci.math.dist": [[10, 1, 1, "", "describe"], [10, 1, 1, "", "histogram"], [10, 1, 1, "", "max"], [10, 1, 1, "", "mean"], [10, 1, 1, "", "merge"], [10, 1, 1, "", "min"], [10, 1, 1, "", "quantile"], [10, 1, 1, "", "stddev"], [10, 1, 1, "", "update"], [10, 1, 1, "", "variance"]], "rxsci.math.formal": [[10, 1, 1, "", "stddev"], [10, 1, 1, "", "variance"]], "rxsci.ops": [[11, 1, 1, "", "assert_"], [11, 1, 1, "", "assert_1"], [11, 1, 1, "", "count"], [11, 1, 1, "", "distinct"], [11, 1, 1, "", "do_action"], [11, 1, 1, "", "filter"], [11, 1, 1, "", "first"], [11, 1, 1, "", "flat_map"], [11, 1, 1, "", "from_iterable"], [11, 1, 1, "", "from_pandas"], [11, 1, 1, "", "group_by"], [11, 1, 1, "", "identity"], [11, 1, 1, "", "last"], [11, 1, 1, "", "map"], [11, 1, 1, "", "multiplex"], [11, 1, 1, "", "progress"], [11, 1, 1, "", "scan"], [11, 1, 1, "", "starmap"], [11, 1, 1, "", "start_with"], [11, 1, 1, "", "take"], [11, 1, 1, "", "tee_map"], [11, 1, 1, "", "to_pandas"], [11, 1, 1, "", "with_latest_from"]], "rxsci.state": [[12, 2, 1, "", "MemoryStore"], [12, 1, 1, "", "with_memory_store"], [12, 1, 1, "", "with_store"]]}, "objtypes": {"0": "py:module", "1": "py:function", "2": "py:class"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "function", "Python function"], "2": ["py", "class", "Python class"]}, "titleterms": {"get": 0, "start": 0, "rxsci": 1, "refer": 1, "document": 1, "content": 1, "indic": 1, "tabl": 1, "instal": 2, "oper": [3, 7, 11], "compress": 4, "gzip": 4, "zstd": 4, "contain": 5, "csv": 5, "json": 5, "data": 6, "error": 7, "frame": 8, "line": 8, "length": 8, "prefix": 8, "io": 9, "math": 10, "distribut": 10, "formal": 10, "base": 11, "state": 12}, "envversion": {"sphinx.domains.c": 3, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 9, "sphinx.domains.index": 1, "sphinx.domains.javascript": 3, "sphinx.domains.math": 2, "sphinx.domains.python": 4, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx": 60}, "alltitles": {"Get Started": [[0, "get-started"]], "RxSci Reference Documentation": [[1, "rxsci-reference-documentation"]], "Contents:": [[1, null]], "Indices and tables": [[1, "indices-and-tables"]], "Installation": [[2, "installation"]], "Operators": [[3, "operators"]], "Compression": [[4, "compression"]], "gzip": [[4, "module-rxsci.compression.z"]], "zstd": [[4, "module-rxsci.compression.zstd"]], "Container": [[5, "container"]], "csv": [[5, "module-rxsci.container.csv"]], "json": [[5, "module-rxsci.container.json"]], "Data": [[6, "module-rxsci.data"]], "Error Operators": [[7, "module-rxsci.error"]], "Framing": [[8, "framing"]], "line": [[8, "module-rxsci.framing.line"]], "length prefix": [[8, "module-rxsci.framing.length_prefix"]], "IO": [[9, "module-rxsci.io"]], "Math": [[10, "module-rxsci.math"]], "Distributed": [[10, "distributed"]], "Formal": [[10, "formal"]], "Base Operators": [[11, "module-rxsci.ops"]], "State": [[12, "module-rxsci.state"]]}, "indexentries": {"compress() (in module rxsci.compression.z)": [[4, "rxsci.compression.z.compress"]], "compress() (in module rxsci.compression.zstd)": [[4, "rxsci.compression.zstd.compress"]], "decompress() (in module rxsci.compression.z)": [[4, "rxsci.compression.z.decompress"]], "module": [[4, "module-rxsci.compression.z"], [4, "module-rxsci.compression.zstd"], [5, "module-rxsci.container.csv"], [5, "module-rxsci.container.json"], [6, "module-rxsci.data"], [7, "module-rxsci.error"], [8, "module-rxsci.framing.length_prefix"], [8, "module-rxsci.framing.line"], [9, "module-rxsci.io"], [10, "module-rxsci.math"], [10, "module-rxsci.math.dist"], [10, "module-rxsci.math.formal"], [11, "module-rxsci.ops"], [12, "module-rxsci.state"]], "rxsci.compression.z": [[4, "module-rxsci.compression.z"]], "rxsci.compression.zstd": [[4, "module-rxsci.compression.zstd"]], "create_line_parser() (in module rxsci.container.csv)": [[5, "rxsci.container.csv.create_line_parser"]], "dump() (in module rxsci.container.csv)": [[5, "rxsci.container.csv.dump"]], "dump() (in module rxsci.container.json)": [[5, "rxsci.container.json.dump"]], "dump_to_file() (in module rxsci.container.csv)": [[5, "rxsci.container.csv.dump_to_file"]], "dump_to_file() (in module rxsci.container.json)": [[5, "rxsci.container.json.dump_to_file"]], "load() (in module rxsci.container.csv)": [[5, "rxsci.container.csv.load"]], "load() (in module rxsci.container.json)": [[5, "rxsci.container.json.load"]], "load_from_file() (in module rxsci.container.csv)": [[5, "rxsci.container.csv.load_from_file"]], "load_from_file() (in module rxsci.container.json)": [[5, "rxsci.container.json.load_from_file"]], "rxsci.container.csv": [[5, "module-rxsci.container.csv"]], "rxsci.container.json": [[5, "module-rxsci.container.json"]], "cache() (in module rxsci.data)": [[6, "rxsci.data.cache"]], "clip() (in module rxsci.data)": [[6, "rxsci.data.clip"]], "fill_none() (in module rxsci.data)": [[6, "rxsci.data.fill_none"]], "lag() (in module rxsci.data)": [[6, "rxsci.data.lag"]], "roll() (in module rxsci.data)": [[6, "rxsci.data.roll"]], "rxsci.data": [[6, "module-rxsci.data"]], "sort() (in module rxsci.data)": [[6, "rxsci.data.sort"]], "split() (in module rxsci.data)": [[6, "rxsci.data.split"]], "time_split() (in module rxsci.data)": [[6, "rxsci.data.time_split"]], "to_deque() (in module rxsci.data)": [[6, "rxsci.data.to_deque"]], "create_error_router() (in module rxsci.error)": [[7, "rxsci.error.create_error_router"]], "ignore() (in module rxsci.error)": [[7, "rxsci.error.ignore"]], "map() (in module rxsci.error)": [[7, "rxsci.error.map"]], "rxsci.error": [[7, "module-rxsci.error"]], "frame() (in module rxsci.framing.length_prefix)": [[8, "rxsci.framing.length_prefix.frame"]], "frame() (in module rxsci.framing.line)": [[8, "rxsci.framing.line.frame"]], "rxsci.framing.length_prefix": [[8, "module-rxsci.framing.length_prefix"]], "rxsci.framing.line": [[8, "module-rxsci.framing.line"]], "unframe() (in module rxsci.framing.length_prefix)": [[8, "rxsci.framing.length_prefix.unframe"]], "unframe() (in module rxsci.framing.line)": [[8, "rxsci.framing.line.unframe"]], "read() (in module rxsci.io)": [[9, "rxsci.io.read"]], "rxsci.io": [[9, "module-rxsci.io"]], "walk() (in module rxsci.io)": [[9, "rxsci.io.walk"]], "write() (in module rxsci.io)": [[9, "rxsci.io.write"]], "describe() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.describe"]], "histogram() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.histogram"]], "max() (in module rxsci.math)": [[10, "rxsci.math.max"]], "max() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.max"]], "mean() (in module rxsci.math)": [[10, "rxsci.math.mean"]], "mean() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.mean"]], "merge() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.merge"]], "min() (in module rxsci.math)": [[10, "rxsci.math.min"]], "min() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.min"]], "quantile() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.quantile"]], "rxsci.math": [[10, "module-rxsci.math"]], "rxsci.math.dist": [[10, "module-rxsci.math.dist"]], "rxsci.math.formal": [[10, "module-rxsci.math.formal"]], "stddev() (in module rxsci.math)": [[10, "rxsci.math.stddev"]], "stddev() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.stddev"]], "stddev() (in module rxsci.math.formal)": [[10, "rxsci.math.formal.stddev"]], "sum() (in module rxsci.math)": [[10, "rxsci.math.sum"]], "update() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.update"]], "variance() (in module rxsci.math)": [[10, "rxsci.math.variance"]], "variance() (in module rxsci.math.dist)": [[10, "rxsci.math.dist.variance"]], "variance() (in module rxsci.math.formal)": [[10, "rxsci.math.formal.variance"]], "assert_() (in module rxsci.ops)": [[11, "rxsci.ops.assert_"]], "assert_1() (in module rxsci.ops)": [[11, "rxsci.ops.assert_1"]], "count() (in module rxsci.ops)": [[11, "rxsci.ops.count"]], "distinct() (in module rxsci.ops)": [[11, "rxsci.ops.distinct"]], "do_action() (in module rxsci.ops)": [[11, "rxsci.ops.do_action"]], "filter() (in module rxsci.ops)": [[11, "rxsci.ops.filter"]], "first() (in module rxsci.ops)": [[11, "rxsci.ops.first"]], "flat_map() (in module rxsci.ops)": [[11, "rxsci.ops.flat_map"]], "from_iterable() (in module rxsci.ops)": [[11, "rxsci.ops.from_iterable"]], "from_pandas() (in module rxsci.ops)": [[11, "rxsci.ops.from_pandas"]], "group_by() (in module rxsci.ops)": [[11, "rxsci.ops.group_by"]], "identity() (in module rxsci.ops)": [[11, "rxsci.ops.identity"]], "last() (in module rxsci.ops)": [[11, "rxsci.ops.last"]], "map() (in module rxsci.ops)": [[11, "rxsci.ops.map"]], "multiplex() (in module rxsci.ops)": [[11, "rxsci.ops.multiplex"]], "progress() (in module rxsci.ops)": [[11, "rxsci.ops.progress"]], "rxsci.ops": [[11, "module-rxsci.ops"]], "scan() (in module rxsci.ops)": [[11, "rxsci.ops.scan"]], "starmap() (in module rxsci.ops)": [[11, "rxsci.ops.starmap"]], "start_with() (in module rxsci.ops)": [[11, "rxsci.ops.start_with"]], "take() (in module rxsci.ops)": [[11, "rxsci.ops.take"]], "tee_map() (in module rxsci.ops)": [[11, "rxsci.ops.tee_map"]], "to_pandas() (in module rxsci.ops)": [[11, "rxsci.ops.to_pandas"]], "with_latest_from() (in module rxsci.ops)": [[11, "rxsci.ops.with_latest_from"]], "memorystore (class in rxsci.state)": [[12, "rxsci.state.MemoryStore"]], "rxsci.state": [[12, "module-rxsci.state"]], "with_memory_store() (in module rxsci.state)": [[12, "rxsci.state.with_memory_store"]], "with_store() (in module rxsci.state)": [[12, "rxsci.state.with_store"]]}})
\ No newline at end of file