fs2-kafka
3.5.1
API
Generated with
fs2-kafka/fs2.kafka/HeaderDeserializer

HeaderDeserializer

fs2.kafka.HeaderDeserializer
See theHeaderDeserializer companion class
object HeaderDeserializer

Attributes

Companion
class
Source
HeaderDeserializer.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Type members

Types

type Attempt[A] = HeaderDeserializer[Either[Throwable, A]]

Alias for HeaderDeserializer[Either[Throwable, A]].

Alias for HeaderDeserializer[Either[Throwable, A]].

Attributes

Source
HeaderDeserializer.scala

Value members

Concrete methods

def apply[A](implicit deserializer: HeaderDeserializer[A]): HeaderDeserializer[A]

Attributes

Source
HeaderDeserializer.scala
def attempt[A](implicit deserializer: Attempt[A]): Attempt[A]

Attributes

Source
HeaderDeserializer.scala
def const[A](a: A): HeaderDeserializer[A]

Creates a new HeaderDeserializer which deserializes all bytes to the specified value of type A.

Creates a new HeaderDeserializer which deserializes all bytes to the specified value of type A.

Attributes

Source
HeaderDeserializer.scala
def delegate[A](deserializer: Deserializer[A]): HeaderDeserializer[A]

Creates a new HeaderDeserializer which delegates deserialization to the specified Kafka Deserializer.

Creates a new HeaderDeserializer which delegates deserialization to the specified Kafka Deserializer. Please note that the close and configure functions won't be called for the delegate. Also, the topic is an empty String and no headers are provided.

Attributes

Source
HeaderDeserializer.scala
def instance[A](f: (Array[Byte]) => A): HeaderDeserializer[A]

Creates a new HeaderDeserializer from the specified function.

Creates a new HeaderDeserializer from the specified function.

Attributes

Source
HeaderDeserializer.scala
def string(charset: Charset): HeaderDeserializer[String]

Creates a new HeaderDeserializer which deserializes String values using the specified Charset.

Creates a new HeaderDeserializer which deserializes String values using the specified Charset. Note that the default String deserializer uses UTF-8.

Attributes

Source
HeaderDeserializer.scala
def uuid(charset: Charset): Attempt[UUID]

Creates a new HeaderDeserializer which deserializes String values using the specified Charset as UUIDs.

Creates a new HeaderDeserializer which deserializes String values using the specified Charset as UUIDs. Note that the default UUID deserializer uses UTF-8.

Attributes

Source
HeaderDeserializer.scala

Implicits

Implicits

implicit val double: Attempt[Double]

Attributes

Source
HeaderDeserializer.scala
implicit val float: Attempt[Float]

Attributes

Source
HeaderDeserializer.scala
implicit val identity: HeaderDeserializer[Array[Byte]]

The identity HeaderDeserializer, which does not perform any kind of deserialization, simply using the input bytes as the output.

The identity HeaderDeserializer, which does not perform any kind of deserialization, simply using the input bytes as the output.

Attributes

Source
HeaderDeserializer.scala
implicit val int: Attempt[Int]

Attributes

Source
HeaderDeserializer.scala
implicit val long: Attempt[Long]

Attributes

Source
HeaderDeserializer.scala
implicit val monad: Monad[HeaderDeserializer]

Attributes

Source
HeaderDeserializer.scala
implicit def option[A](implicit deserializer: HeaderDeserializer[A]): HeaderDeserializer[Option[A]]

The option HeaderDeserializer returns None when the bytes are null, and otherwise deserializes using the deserializer for the type A, wrapping the result in Some.

The option HeaderDeserializer returns None when the bytes are null, and otherwise deserializes using the deserializer for the type A, wrapping the result in Some.

Attributes

Source
HeaderDeserializer.scala
implicit val short: Attempt[Short]

Attributes

Source
HeaderDeserializer.scala
implicit val string: HeaderDeserializer[String]

Attributes

Source
HeaderDeserializer.scala
implicit val unit: HeaderDeserializer[Unit]

Attributes

Source
HeaderDeserializer.scala
implicit val uuid: Attempt[UUID]

Attributes

Source
HeaderDeserializer.scala
Generated with