StompFrame

zio.http.stomp.StompFrame
See theStompFrame companion class
object StompFrame

Attributes

Companion
class
Source
StompFrame.scala
Graph
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
StompFrame.type

Members list

Type members

Inherited and Abstract types

type MirroredElemLabels <: Tuple

The names of the product elements

The names of the product elements

Attributes

Inherited from:
Mirror
Source
Mirror.scala
type MirroredLabel <: String

The name of the type

The name of the type

Attributes

Inherited from:
Mirror
Source
Mirror.scala

Value members

Concrete methods

def abort(transaction: String): StompFrame

Attributes

Source
StompFrame.scala
def ack(id: String, transaction: Option[String] = ...): StompFrame

Attributes

Source
StompFrame.scala
def begin(transaction: String): StompFrame

Attributes

Source
StompFrame.scala
def commit(transaction: String): StompFrame

Attributes

Source
StompFrame.scala
def connect(host: String, login: Option[String] = ..., passcode: Option[String] = ..., acceptVersion: String = ..., heartBeat: Option[(Int, Int)] = ...): StompFrame

Attributes

Source
StompFrame.scala
def connected(version: String = ..., session: Option[String] = ..., server: Option[String] = ..., heartBeat: Option[(Int, Int)] = ...): StompFrame

Attributes

Source
StompFrame.scala
def decode(bytes: Chunk[Byte]): Either[String, StompFrame]

Parse a STOMP frame from bytes

Parse a STOMP frame from bytes

Attributes

Source
StompFrame.scala
def disconnect(receipt: Option[String] = ...): StompFrame

Attributes

Source
StompFrame.scala
def error(message: Option[String] = ..., body: Option[String] = ..., receiptId: Option[String] = ...): StompFrame

Attributes

Source
StompFrame.scala
def heartbeat: StompFrame

Attributes

Source
StompFrame.scala
def message(destination: String, messageId: String, subscription: String, body: Chunk[Byte], contentType: Option[String] = ..., additionalHeaders: Map[String, String] = ...): StompFrame

Attributes

Source
StompFrame.scala
def nack(id: String, transaction: Option[String] = ...): StompFrame

Attributes

Source
StompFrame.scala
def receipt(receiptId: String): StompFrame

Attributes

Source
StompFrame.scala
def send(destination: String, body: Chunk[Byte], contentType: Option[String] = ..., additionalHeaders: Map[String, String] = ...): StompFrame

Attributes

Source
StompFrame.scala
def send(destination: String, body: String, contentType: Option[String], additionalHeaders: Map[String, String])(implicit di: DummyImplicit): StompFrame

Attributes

Source
StompFrame.scala
def subscribe(destination: String, id: String, ack: String = ..., additionalHeaders: Map[String, String] = ...): StompFrame

Attributes

Source
StompFrame.scala
def unsubscribe(id: String): StompFrame

Attributes

Source
StompFrame.scala

Concrete fields

val streamDecoder: ZPipeline[Any, String, Byte, StompFrame]

Stream decoder for STOMP frames

Stream decoder for STOMP frames

Attributes

Source
StompFrame.scala
val streamEncoder: ZPipeline[Any, Nothing, StompFrame, Byte]

Stream encoder for STOMP frames

Stream encoder for STOMP frames

Attributes

Source
StompFrame.scala

Implicits

Implicits

implicit val schema: Schema[StompFrame]

Attributes

Source
StompFrame.scala