valencik

import cats.effect.IO
import fs2.{Pipe, Pull, Stream}

object JsonlPayloadPipe {

  /** Builds a pipe that transforms a stream of JSON strings into payloads for the Elasticsearch Bulk
    * API. Each input string represents a JSON document to be sent to the Bulk API. The JSONs are
    * gathered, interspersed with `delimiter`, and packaged into payload strings up to a maximum
    * size of `batchMax` bytes.
    *

valencik

//> using scala "2.13.10"
//> using lib "org.apache.lucene:lucene-core:9.5.0"
//> using lib "org.apache.lucene:lucene-analysis-common:9.5.0"
//> using lib "org.apache.lucene:lucene-memory:9.5.0"
//> using lib "org.apache.lucene:lucene-queryparser:9.5.0"

import org.apache.lucene.analysis.standard.StandardAnalyzer
import org.apache.lucene.index.memory.MemoryIndex
import org.apache.lucene.queryparser.flexible.standard.StandardQueryParser

valencik

<li class="indented0" name="fs2.Stream.InvariantOps#observe" group="Ungrouped" fullcomment="yes" data-isabs="false" visbl="pub">
    <a id="observe(p:fs2.Pipe[F,O,Nothing])(implicitF:cats.effect.Concurrent[F]):fs2.Stream[F,O]" class="anchorToMember"></a><a id="observe(Pipe[F,O,Nothing])(Concurrent[F]):Stream[F,O]" class="anchorToMember"></a>
    <span class="permalink">
        <a href="../fs2/Stream$$InvariantOps.html#observe(p:fs2.Pipe[F,O,Nothing])(implicitF:cats.effect.Concurrent[F]):fs2.Stream[F,O]" title="Permalink"><i class="material-icons"></i></a>
    </span>
    <span class="modifier_kind"><span class="modifier"></span> <span class="kind">def</span></span>
    <span class="symbol">
        <span class="name">observe</span>
        <span class="params">
            (

valencik

Cats

The Typelevel ecosystem of libraries for functional programming in Scala provides several fundamental type classes for representing the capabilities of different computations.

Functor

Effect: Transforming the value inside an effect by mapping over it

[📚 Functor docs][docs-functor]

valencik

I'm writing purely functional code in Scala, using the ecosystem of Typelevel libraries. Specifically I'm using cats-effect, fs2, and http4s.

I have a list of URLs, how do make parallel GET requests to them and write their bytes to disk?

---

Here is one way you can do it using the cats-effect, fs2, and http4s libraries in Scala:

Import the necessary libraries:

valencik

Quoted sections are copy paste from https://adventofcode.com/2022/day/1

Plain text are my manual inputs

Code blocks are GPT-3s responses

---

valencik

# Previously Seen Queries

- can i cancel a refund
- how can i cancel an order
- cancel my account
- can i dropship using paypal
- paypal payments
- paypal providers

valencik

• Download this gist as a zip and extract
• Open chrome://extensions
• Enable Developer mode
• Click Load unpacked extension... and select the extracted folder
• 💵 Profit 💵

Created by the SMU CS Society

valencik

AndrewMBP:units-2.11 andrew$ ./configure
checking for gcc... gcc
checking whether the C compiler works... yes
checking for C compiler default output file name... a.out
checking for suffix of executables...
checking whether we are cross compiling... no
checking for suffix of object files... o
checking whether we are using the GNU C compiler... yes
checking whether gcc accepts -g... yes
checking for gcc option to accept ISO C89... none needed

valencik

$ls -l presentation/
total 16
-rw-r--r--  1 andrew  admin  153  7 Sep 14:58 script.vim
-rw-r--r--  1 andrew  admin  360  7 Sep 14:58 slide001.md
-----

$cat script.vim
set nonumber
set hidden
noremap <PageUp> :bp<CR>