@qualithm/mqtt-wire - v0.1.5
    Preparing search index...

    Module index

    Server-side MQTT protocol codec and connection state machine for JavaScript and TypeScript runtimes.

    Classes

    BinaryReader
    BinaryWriter
    MqttWire
    PacketIdAllocator
    PacketIdExhaustedError
    PacketSizeCalculator
    ProtocolError
    QoSFlowTracker
    StateError
    StreamFramer
    TopicAliasError
    TopicAliasManager
    TopicAliasMap

    Type Aliases

    AckResult
    AuthPacket
    AuthProperties
    ConnackPacket
    ConnackProperties
    ConnectionState
    ConnectionStateChange
    ConnectPacket
    ConnectProperties
    DecodedPacket
    DecodeError
    DecodeErrorCode
    DecodeFailure
    DecodeResult
    DecodeSuccess
    DisconnectPacket
    DisconnectProperties
    FrameResult
    InboundFlow
    LifecycleHooks
    MqttBinaryDecodeResult
    MqttPacket
    MqttStringDecodeResult
    MqttWireOptions
    OnConnectHook
    OnDisconnectHook
    OnErrorHook
    OnPublishHook
    OnSendHook
    OnSubscribeHook
    OnUnsubscribeHook
    OutboundAliasResult
    OutboundFlow
    PacketFrame
    PacketOfType
    PacketType
    PingreqPacket
    PingrespPacket
    PropertyId
    ProtocolVersion
    PubackPacket
    PubAckProperties
    PubcompPacket
    PublishPacket
    PublishProperties
    PubrecPacket
    PubrelPacket
    QoS
    QoS1InboundFlow
    QoS1OutboundFlow
    QoS2InboundFlow
    QoS2InboundState
    QoS2OutboundFlow
    QoS2OutboundState
    QoSFlow
    ReasonCode
    SharedSubscription
    SubackPacket
    SubackProperties
    SubscribePacket
    SubscribeProperties
    Subscription
    SubscriptionOptions
    UnsubackPacket
    UnsubackProperties
    UnsubscribePacket
    UnsubscribeProperties
    UserProperty
    VarintDecodeValue
    WillMessage
    WillProperties

    Variables

    DEFAULT_MAXIMUM_PACKET_SIZE
    DEFAULT_RECEIVE_MAXIMUM
    DEFAULT_WIRE_OPTIONS
    MAX_PACKET_ID
    MAX_PACKET_SIZE
    MAX_TOPIC_ALIAS
    MAX_TOPIC_LENGTH
    MAX_VARIABLE_BYTE_INTEGER
    MAX_VARIABLE_BYTE_INTEGER_LENGTH
    MIN_PACKET_ID
    PACKET_TYPE_NAME
    PacketType
    PROPERTY_ID_NAME
    PropertyId
    PROTOCOL_LEVEL
    REASON_CODE_NAME
    SHARED_SUBSCRIPTION_PREFIX
    WILDCARD_MULTI
    WILDCARD_SINGLE

    Functions

    decodeError
    decodeMqttBinary
    decodeMqttString
    decodePacket
    decodeUtf8
    decodeVariableByteInteger
    encodeMqttBinary
    encodeMqttString
    encodePacket
    encodeUtf8
    encodeVariableByteInteger
    encodeVariableByteIntegerToArray
    err
    hasCompleteVariableByteInteger
    isErrorReasonCode
    isSharedSubscription
    isSuccessReasonCode
    isValidMqttString
    isValidTopicFilter
    isValidTopicName
    joinTopicLevels
    ok
    parsePacketFrame
    parseSharedSubscription
    parseTopicLevels
    readPacketFrame
    topicMatches
    utf8ByteLength
    validateMqttUtf8
    validateTopicFilter
    validateTopicName
    variableByteIntegerLength