sealed abstract class Headers extends AnyRef

Headers represent an immutable append-only collection of Headers. To create a new Headers instance, you can use Headers#apply or Headers#empty and add an instance of Header using append.

Source
Headers.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Headers
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def append[V](key: String, value: V)(implicit arg0: HeaderSerializer[V]): Headers

    Creates a new Headers instance including a Header with the specified key and value.

  2. abstract def append(header: Header): Headers

    Creates a new Headers instance with the specified Header included.

  3. abstract def asJava: KafkaHeaders

    The Headers as an immutable Java Kafka Headers instance.

  4. abstract def concat(that: Headers): Headers

    Appends the specified Headers after these headers.

  5. abstract def exists(key: String): Boolean

    Returns true if a header with the specified key exists; otherwise false.

  6. abstract def isEmpty: Boolean

    true if no Headers are included; otherwise false.

  7. abstract def toChain: Chain[Header]

    The included Headers as a Chain.

  8. abstract def withKey(key: String): Option[Header]

    Returns the first header with the specified key, wrapped in Some, or None if no such header exists.

    Returns the first header with the specified key, wrapped in Some, or None if no such header exists. The apply function is an alias.

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def apply(key: String): Option[Header]

    Returns the first header with the specified key, wrapped in Some, or None if no such header exists.

    Returns the first header with the specified key, wrapped in Some, or None if no such header exists. Alias for withKey.

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def nonEmpty: Boolean

    true if at least one Header is included; otherwise false.

  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  18. def toString(): String
    Definition Classes
    AnyRef → Any
  19. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped