dsebban

import scala.concurrent.duration._
import $ivy.`com.spinoco:fs2-kafka_2.12:0.4.0-M2`
import spinoco.protocol.kafka.{Broker, PartitionId, ProtocolVersion, TopicName}
import spinoco.fs2.kafka
import spinoco.fs2.kafka._

import cats.effect.IO

object Fs2KafkaClientResources {

dsebban

object Transducer {
    sealed trait Process[I, O]
    case class Halt[I,O]() extends Process[I,O]
    case class Emit[I,O](h: O, tail: Process[I, O]) extends Process[I,O]
    case class Await[I,O](recv: Option[I] => Process[I,O]) extends Process[I,O]
}

import Transducer._

object ProcessOps {

dsebban

import coursier.core.Authentication, coursier.MavenRepository

interp.repositories() ++= Seq(MavenRepository(
      "http://dl.bintray.com/ovotech/maven"
    ))

@

import $ivy.`com.ovoenergy::fs2-kafka-client:0.1.13`

dsebban

amm
Loading...
Welcome to the Ammonite Repl 1.0.3-20-75e58ac
(Scala 2.12.4 Java 1.8.0_92)
If you like Ammonite, please support our development at www.patreon.com/lihaoyi
@ import coursier.core.Authentication, coursier.MavenRepository
import coursier.core.Authentication, coursier.MavenRepository

@ interp.repositories() ++= Seq(MavenRepository(
      "http://dl.bintray.com/ovotech/maven"

dsebban

input	output	# implementations
a: A	A	1
a: A, b: A	A	2
as: List[A]	List[A]	little bit more
a: A	Int	a lot more!

dsebban

T => List[T]

dsebban

trait WithMap[F[_]] {
}

dsebban

List("a") -> List[String] -> List           -> ???
// value     proper type     first order type  ???

dsebban

scala> val l: List = List(1,2,3)
<console>:12: error: type List takes type parameters
       val l: List = List(1,2,3)
              ^

dsebban

scala> val name = "daniel"
name: String = daniel

scala> val one = 1
one: Int = 1

scala> val oneAndTwoAsTuple = (1,2)
oneAndTwoAsTuple: (Int, Int) = (1,2)

scala> val oneAndTwoInAList = List(1,2)