Skip to content
#

fs2

Here are 139 public repositories matching this topic...

vlovgr
vlovgr commented Oct 11, 2019

Similarly to #234, it would be useful to provide functions for creating test KafkaProducers.

A good first function would be one which yields somewhat sensible default RecordMetadata.

object KafkaProducer {
  def unit[F[_], K, V](implicit F: Sync[F]): F[KafkaProducer[F, K, V]] = ???
}

Likely, this would require some internal state, hence F[KafkaProducer[F, K, V]].

sloshy
sloshy commented Jun 20, 2020

Sometimes it might be useful to know what event triggered what state. The internals of the various EventState implementations should be flexible enough to handle this option. In particular, this change would require rethinking the idea of an "initial state" to always require some incoming event. For the default case where there is no initial event, it can be modeled internally using Option[E]

Improve this page

Add a description, image, and links to the fs2 topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the fs2 topic, visit your repo's landing page and select "manage topics."

Learn more