deploy: 2a16264

gnieh · Mar 13, 2024 · adf73c9 · adf73c9
1 parent 8b1874d
commit adf73c9
Show file tree

Hide file tree

Showing 18 changed files with 33 additions and 36 deletions.
diff --git a/cookbooks/jq/index.html b/cookbooks/jq/index.html
@@ -256,7 +256,7 @@ <h3 id="transforming" class="section"><a class="anchor-link left" href="#transfo
         <pre class="keep-together pdf epub"><code class="nohighlight"><span class="keyword">import</span><span> </span><span class="identifier">fs2</span><span>.</span><span class="identifier">data</span><span>.</span><span class="identifier">json</span><span>.</span><span class="identifier">jq</span><span>.</span><span class="type-name">Compiler</span><span>
 
 </span><span class="keyword">val</span><span> </span><span class="identifier">queryCompiler</span><span> = </span><span class="type-name">Compiler</span><span>[</span><span class="type-name">IO</span><span>]
-</span><span class="comment">// queryCompiler: Compiler[IO] = fs2.data.json.jq.internal.ESPJqCompiler@51d880d
+</span><span class="comment">// queryCompiler: Compiler[IO] = fs2.data.json.jq.internal.ESPJqCompiler@40f82cb8
 </span><span>
 </span><span class="keyword">val</span><span> </span><span class="identifier">queryPipe</span><span> = </span><span class="identifier">queryCompiler</span><span>.</span><span class="identifier">compile</span><span>(</span><span class="identifier">query</span><span>).</span><span class="identifier">unsafeRunSync</span><span>()
 </span><span class="comment">// queryPipe: fs2.package.Pipe[IO, json.Token, json.Token] = &lt;function1&gt;</span></code></pre>

diff --git a/cookbooks/jsonlines/index.html b/cookbooks/jsonlines/index.html
@@ -279,8 +279,6 @@ <h2 id="producing-json-lines-data" class="section"><a class="anchor-link left" h
         <p>Similarly, using <code>fs2</code> and <code>fs2-data</code> operators, we can generate a stream that will emit each record on a single line.</p>
         <pre class="keep-together pdf epub"><code class="nohighlight"><span class="keyword">def</span><span> </span><span class="declaration-name">writeJsonLines</span><span>(</span><span class="identifier">input</span><span>: </span><span class="type-name">Stream</span><span>[</span><span class="type-name">IO</span><span>, </span><span class="type-name">Json</span><span>]): </span><span class="type-name">Stream</span><span>[</span><span class="type-name">IO</span><span>, </span><span class="type-name">Byte</span><span>] =
   </span><span class="identifier">input</span><span>
-    .</span><span class="identifier">chunkLimit</span><span>(</span><span class="number-literal">1</span><span>)
-    .</span><span class="identifier">unchunks</span><span>
     .</span><span class="identifier">flatMap</span><span> { </span><span class="identifier">data</span><span> =&gt;
       </span><span class="comment">// rule #2: values must be encoded on single lines
 </span><span>      </span><span class="type-name">Stream</span><span>.</span><span class="identifier">emit</span><span>(</span><span class="identifier">data</span><span>).</span><span class="identifier">through</span><span>(</span><span class="identifier">fs2</span><span>.</span><span class="identifier">data</span><span>.</span><span class="identifier">json</span><span>.</span><span class="identifier">ast</span><span>.</span><span class="identifier">tokenize</span><span>).</span><span class="identifier">through</span><span>(</span><span class="identifier">fs2</span><span>.</span><span class="identifier">data</span><span>.</span><span class="identifier">json</span><span>.</span><span class="identifier">render</span><span>.</span><span class="identifier">compact</span><span>)
@@ -296,8 +294,7 @@ <h2 id="producing-json-lines-data" class="section"><a class="anchor-link left" h
   .</span><span class="identifier">readAll</span><span>(</span><span class="type-name">Path</span><span>(</span><span class="string-literal">&quot;site/cookbooks/data/json/sample.json&quot;</span><span>))
   .</span><span class="identifier">through</span><span>(</span><span class="identifier">fs2</span><span>.</span><span class="identifier">text</span><span>.</span><span class="identifier">utf8</span><span>.</span><span class="identifier">decode</span><span>)
   .</span><span class="identifier">through</span><span>(</span><span class="identifier">fs2</span><span>.</span><span class="identifier">data</span><span>.</span><span class="identifier">json</span><span>.</span><span class="identifier">tokens</span><span>)
-  .</span><span class="identifier">through</span><span>(</span><span class="identifier">fs2</span><span>.</span><span class="identifier">data</span><span>.</span><span class="identifier">json</span><span>.</span><span class="identifier">jsonpath</span><span>.</span><span class="identifier">filter</span><span>.</span><span class="identifier">values</span><span>(</span><span class="string-literal">jsonpath&quot;$$[*]&quot;</span><span>))
-  .</span><span class="identifier">take</span><span>(</span><span class="number-literal">5</span><span>)
+  .</span><span class="identifier">through</span><span>(</span><span class="identifier">fs2</span><span>.</span><span class="identifier">data</span><span>.</span><span class="identifier">json</span><span>.</span><span class="identifier">jsonpath</span><span>.</span><span class="identifier">filter</span><span>.</span><span class="identifier">values</span><span>(</span><span class="string-literal">jsonpath&quot;$$[0:4]&quot;</span><span>))
   .</span><span class="identifier">through</span><span>(</span><span class="identifier">writeJsonLines</span><span>)
   .</span><span class="identifier">through</span><span>(</span><span class="identifier">fs2</span><span>.</span><span class="identifier">text</span><span>.</span><span class="identifier">utf8</span><span>.</span><span class="identifier">decode</span><span>)
   .</span><span class="identifier">compile</span><span>

diff --git a/documentation/cbor-json/index.html b/documentation/cbor-json/index.html
@@ -264,7 +264,7 @@ <h2 id="json-to-cbor" class="section"><a class="anchor-link left" href="#json-to
 //   NegativeInt(
 //     bytes = Chunk(
 //       bytes = View(
-//         at = scodec.bits.ByteVector$AtArray@19801d57,
+//         at = scodec.bits.ByteVector$AtArray@71d1f049,
 //         offset = 0L,
 //         size = 1L
 //       )
@@ -273,7 +273,7 @@ <h2 id="json-to-cbor" class="section"><a class="anchor-link left" href="#json-to
 //   PositiveInt(
 //     bytes = Chunk(
 //       bytes = View(
-//         at = scodec.bits.ByteVector$AtArray@709dd0b8,
+//         at = scodec.bits.ByteVector$AtArray@4e37ab23,
 //         offset = 0L,
 //         size = 2L
 //       )

diff --git a/documentation/cbor/index.html b/documentation/cbor/index.html
@@ -187,7 +187,7 @@ <h3 id="parsing-1" class="section"><a class="anchor-link left" href="#parsing-1"
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@26a7fe5b,
+//           at = scodec.bits.ByteVector$AtArray@395abe7c,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -197,7 +197,7 @@ <h3 id="parsing-1" class="section"><a class="anchor-link left" href="#parsing-1"
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@1f9195b,
+//           at = scodec.bits.ByteVector$AtArray@bdcbad6,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -206,7 +206,7 @@ <h3 id="parsing-1" class="section"><a class="anchor-link left" href="#parsing-1"
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@4210d211,
+//           at = scodec.bits.ByteVector$AtArray@6492b050,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -216,7 +216,7 @@ <h3 id="parsing-1" class="section"><a class="anchor-link left" href="#parsing-1"
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@63838649,
+//           at = scodec.bits.ByteVector$AtArray@6fe11836,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -225,7 +225,7 @@ <h3 id="parsing-1" class="section"><a class="anchor-link left" href="#parsing-1"
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@7acfe944,
+//           at = scodec.bits.ByteVector$AtArray@3a4f2e8,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -340,7 +340,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@33350487,
+//           at = scodec.bits.ByteVector$AtArray@6d40f240,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -350,7 +350,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@77f1d8aa,
+//           at = scodec.bits.ByteVector$AtArray@1ca1cf88,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -359,7 +359,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@8bfa9d3,
+//           at = scodec.bits.ByteVector$AtArray@7b664482,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -369,7 +369,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@dbff449,
+//           at = scodec.bits.ByteVector$AtArray@5f71dab4,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -378,7 +378,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@1635d845,
+//           at = scodec.bits.ByteVector$AtArray@3549e1e8,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -400,7 +400,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@6ff876a1,
+//           at = scodec.bits.ByteVector$AtArray@2786b546,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -410,7 +410,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@1a7cbbbc,
+//           at = scodec.bits.ByteVector$AtArray@6e0da760,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -419,7 +419,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@68931906,
+//           at = scodec.bits.ByteVector$AtArray@3ff8646f,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -429,7 +429,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@505c03a1,
+//           at = scodec.bits.ByteVector$AtArray@45c494d9,
 //           offset = 0L,
 //           size = 1L
 //         )
@@ -438,7 +438,7 @@ <h3 id="serializing-2" class="section"><a class="anchor-link left" href="#serial
 //     PositiveInt(
 //       bytes = Chunk(
 //         bytes = View(
-//           at = scodec.bits.ByteVector$AtArray@7cbd2a75,
+//           at = scodec.bits.ByteVector$AtArray@57fa25a2,
 //           offset = 0L,
 //           size = 1L
 //         )

diff --git a/documentation/csv/generic/index.html b/documentation/csv/generic/index.html
@@ -190,7 +190,7 @@ <h2 id="derivation-of-celldecoder-cellencoder" class="section"><a class="anchor-
 }
 
 </span><span class="keyword">implicit</span><span> </span><span class="keyword">val</span><span> </span><span class="identifier">stateDecoder</span><span> = </span><span class="identifier">deriveCellDecoder</span><span>[</span><span class="type-name">State</span><span>]
-</span><span class="comment">// stateDecoder: CellDecoder[State] = fs2.data.csv.generic.internal.DerivedCellDecoder$$anonfun$coproductDecoder$3@54726307
+</span><span class="comment">// stateDecoder: CellDecoder[State] = fs2.data.csv.generic.internal.DerivedCellDecoder$$anonfun$coproductDecoder$3@1cae95bb
 // use stateDecoder to derive decoders for rows...or just test:
 </span><span class="identifier">stateDecoder</span><span>(</span><span class="string-literal">&quot;On&quot;</span><span>)
 </span><span class="comment">// res1: DecoderResult[State] = Right(value = On)
@@ -199,7 +199,7 @@ <h2 id="derivation-of-celldecoder-cellencoder" class="section"><a class="anchor-
 </span><span>
 </span><span class="comment">// same goes for the encoder
 </span><span class="keyword">implicit</span><span> </span><span class="keyword">val</span><span> </span><span class="identifier">stateEncoder</span><span> = </span><span class="identifier">deriveCellEncoder</span><span>[</span><span class="type-name">State</span><span>]
-</span><span class="comment">// stateEncoder: CellEncoder[State] = fs2.data.csv.generic.internal.DerivedCellEncoder$$anonfun$coproductEncoder$3@4dc4797b
+</span><span class="comment">// stateEncoder: CellEncoder[State] = fs2.data.csv.generic.internal.DerivedCellEncoder$$anonfun$coproductEncoder$3@5181511c
 </span><span class="identifier">stateEncoder</span><span>(</span><span class="type-name">State</span><span>.</span><span class="type-name">On</span><span>)
 </span><span class="comment">// res3: String = &quot;On&quot;</span></code></pre>
         <p>The generic derivation for cell decoders also supports renaming and deriving instances for unary product types (case classes with one field):</p>
@@ -213,19 +213,19 @@ <h2 id="derivation-of-celldecoder-cellencoder" class="section"><a class="anchor-
 
 </span><span class="comment">// works as we have an implicit CellDecoder[String]
 </span><span class="keyword">implicit</span><span> </span><span class="keyword">val</span><span> </span><span class="identifier">unknownDecoder</span><span> = </span><span class="identifier">deriveCellDecoder</span><span>[</span><span class="type-name">Advanced</span><span>.</span><span class="type-name">Unknown</span><span>]
-</span><span class="comment">// unknownDecoder: CellDecoder[Advanced.Unknown] = fs2.data.csv.generic.internal.DerivedCellDecoder$$anonfun$unaryProductDecoder$3@4a75b0f0
+</span><span class="comment">// unknownDecoder: CellDecoder[Advanced.Unknown] = fs2.data.csv.generic.internal.DerivedCellDecoder$$anonfun$unaryProductDecoder$3@1c8f920b
 </span><span class="keyword">implicit</span><span> </span><span class="keyword">val</span><span> </span><span class="identifier">advancedDecoder</span><span> = </span><span class="identifier">deriveCellDecoder</span><span>[</span><span class="type-name">Advanced</span><span>]
-</span><span class="comment">// advancedDecoder: CellDecoder[Advanced] = fs2.data.csv.generic.internal.DerivedCellDecoder$$anonfun$coproductDecoder$3@15ab1d9e
+</span><span class="comment">// advancedDecoder: CellDecoder[Advanced] = fs2.data.csv.generic.internal.DerivedCellDecoder$$anonfun$coproductDecoder$3@cf7e91c
 </span><span>
 </span><span class="identifier">advancedDecoder</span><span>(</span><span class="string-literal">&quot;Active&quot;</span><span>)
 </span><span class="comment">// res4: DecoderResult[Advanced] = Right(value = On)
 </span><span class="identifier">advancedDecoder</span><span>(</span><span class="string-literal">&quot;Off&quot;</span><span>)
 </span><span class="comment">// res5: DecoderResult[Advanced] = Right(value = Unknown(name = &quot;Off&quot;))
 </span><span>
 </span><span class="keyword">implicit</span><span> </span><span class="keyword">val</span><span> </span><span class="identifier">unknownEncoder</span><span> = </span><span class="identifier">deriveCellEncoder</span><span>[</span><span class="type-name">Advanced</span><span>.</span><span class="type-name">Unknown</span><span>]
-</span><span class="comment">// unknownEncoder: CellEncoder[Advanced.Unknown] = fs2.data.csv.generic.internal.DerivedCellEncoder$$anonfun$unaryProductEncoder$3@52862e77
+</span><span class="comment">// unknownEncoder: CellEncoder[Advanced.Unknown] = fs2.data.csv.generic.internal.DerivedCellEncoder$$anonfun$unaryProductEncoder$3@641cb674
 </span><span class="keyword">implicit</span><span> </span><span class="keyword">val</span><span> </span><span class="identifier">advancedEncoder</span><span> = </span><span class="identifier">deriveCellEncoder</span><span>[</span><span class="type-name">Advanced</span><span>]
-</span><span class="comment">// advancedEncoder: CellEncoder[Advanced] = fs2.data.csv.generic.internal.DerivedCellEncoder$$anonfun$coproductEncoder$3@3ce78afd
+</span><span class="comment">// advancedEncoder: CellEncoder[Advanced] = fs2.data.csv.generic.internal.DerivedCellEncoder$$anonfun$coproductEncoder$3@3f4e025a
 </span><span>
 </span><span class="identifier">advancedEncoder</span><span>(</span><span class="type-name">Advanced</span><span>.</span><span class="type-name">On</span><span>)
 </span><span class="comment">// res6: String = &quot;Active&quot;
@@ -269,7 +269,7 @@ <h2 id="derivation-of-csvrowdecoder" class="section"><a class="anchor-link left"
         <pre><code class="nohighlight"><span class="keyword">import</span><span> </span><span class="identifier">fs2</span><span>.</span><span class="identifier">data</span><span>.</span><span class="identifier">csv</span><span>.</span><span class="identifier">generic</span><span>.</span><span class="identifier">semiauto</span><span>.</span><span class="identifier">_</span><span>
 
 </span><span class="keyword">implicit</span><span> </span><span class="keyword">val</span><span> </span><span class="type-name">MyRowDecoder</span><span>: </span><span class="type-name">CsvRowDecoder</span><span>[</span><span class="type-name">MyRow</span><span>, </span><span class="type-name">String</span><span>] = </span><span class="identifier">deriveCsvRowDecoder</span><span>[</span><span class="type-name">MyRow</span><span>]
-</span><span class="comment">// MyRowDecoder: CsvRowDecoder[MyRow, String] = fs2.data.csv.generic.internal.DerivedCsvRowDecoder$$anon$1@3c1895fd
+</span><span class="comment">// MyRowDecoder: CsvRowDecoder[MyRow, String] = fs2.data.csv.generic.internal.DerivedCsvRowDecoder$$anon$1@73632c2c
 </span><span>
 </span><span class="keyword">val</span><span> </span><span class="identifier">decoded</span><span> = </span><span class="identifier">stream</span><span>.</span><span class="identifier">through</span><span>(</span><span class="identifier">decodeUsingHeaders</span><span>[</span><span class="type-name">MyRow</span><span>]())
 </span><span class="comment">// decoded: Stream[[x]Fallible[x], MyRow] = Stream(..)