Itamar Ravid

Suggestion: simplify API by using `AsyncHandler[Id]` instead of overloads for blocking methods

1

Instead of having overloads for the blocking methods on `Consumer`, an `AsyncHandler[Id]` can be provided instead with a separate import.

False positive when adding a method to a class with the same name as a method in the companion object

3

Given this in a previous version: ```scala sealed abstract class ZManaged[R, E, A] object ZManaged { case class Reservation[R, E, A] def reserve[R, E, A](r: Reservation[R, E, A]): ZManaged[R, E,...

Add a typed `col` function for creating column references

9

Resolves #186. Would be a good idea to wait for #110 before merging this to avoid conflict on `SelectTests.scala`.

Provide a way to construct a `TypedColumn` reference from a Symbol

8

Currently, we cannot chain selects that reference columns introduced in a select without introducing intermediate vals. Here's a (contrived) example: ```scala case class X2(i: Int, j: Int) val ds =...

Pickler generation fails for object

3

Hi, I'm trying to generate a pickler for an object graph. The compilation fails after a while, suggesting to use -Xlog-implicits to see why. After adding that option, this is...

Add a variant of ZStream#throttleShape that allows dynamically changing the throttling rate

7

Not sure about the interface yet. cc @vasilmkd

Design session summary

3

## Purpose and requirements The purpose of this library is to provide a solution for creating distributed stream processing applications. These applications read data from data sources that (optionally) support...

Using the mechanisms from #2, provide more opinionated interfaces for common idioms of working with RocksDB: - A plain key/value store - A key/value store that supports prefix scans for...

Should support opening different databases, writing to different ColumnFamilies ColumnFamily handles could probably be implemented as a type member on the algebra to keep them opaque