Skip to content

Instantly share code, notes, and snippets.

@Algiras

Algiras/KafkaGreyhound_2.scala

Created December 11, 2020 14:27
Show Gist options
  • Save Algiras/c6be5fcb591ecc500e6a9a766d30a4cb to your computer and use it in GitHub Desktop.
Save Algiras/c6be5fcb591ecc500e6a9a766d30a4cb to your computer and use it in GitHub Desktop.
Download ZIP
Raw
KafkaGreyhound_2.scala
trait Topic[VReq, V] {
def record(request: VReq): RIO[Blocking, UUID]
def records: ZManaged[RecordConsumer.Env, Throwable, ZStream[Any, Nothing, V]]
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment