suspend fun <Error class: unknown class><<Error class: unknown class>>.asEventStreamHttpBody(scope: <Error class: unknown class>): <Error class: unknown class>

Transform a stream of encoded messages into an HttpBody.

encode

fun <Error class: unknown class><Message>.encode(): <Error class: unknown class><<Error class: unknown class>>

Transform the stream of messages into a stream of raw bytes. Each element of the resulting flow is the encoded version of the corresponding message

expectBool

fun HeaderValue.expectBool(): Boolean

expectByte

fun HeaderValue.expectByte(): Byte

expectByteArray

fun HeaderValue.expectByteArray(): ByteArray

expectInt16

fun HeaderValue.expectInt16(): Short

expectInt32

fun HeaderValue.expectInt32(): Int

expectInt64

fun HeaderValue.expectInt64(): Long

expectString

fun HeaderValue.expectString(): String

expectTimestamp

fun HeaderValue.expectTimestamp(): <Error class: unknown class>

expectUuid

fun HeaderValue.expectUuid(): <Error class: unknown class>

sign

fun <Error class: unknown class><Message>.sign(context: <Error class: unknown class>): <Error class: unknown class><Message>

Creates a flow that signs each event stream message with the given signing config.

type

fun Message.type(): MessageType

Parse the protocol level headers into a concrete MessageType