@ file : Suppress (" INTERFACE _ WITH _ SUPER CLASS ", Ġ" OVER RID ING _ FINAL _ MEMBER ", Ġ" RETURN _ TYPE _ MIS MATCH _ ON _ OVERRIDE ", Ġ" CONF LI CT ING _ OVERLOAD S ", Ġ" EXTERNAL _ DE LEG ATION ") Ċ Ċ package Ġde . rob ol ab . client . communication . bindings Ċ Ċ external Ġinterface ĠI Subscription Grant Ġ{ ĊĠĠĠ Ġvar Ġtopic : ĠString ĊĠĠĠ Ġvar Ġq os : Ġdynamic Ġ/* ĠQ oS Ġ| ĠNumber Ġ*/ ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally ĊĠĠĠ Ġvar Ġnl : ĠBoolean ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally ĊĠĠĠ Ġvar Ġrap : ĠBoolean ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally ĊĠĠĠ Ġvar Ġrh : ĠNumber ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally Ċ } Ċ Ċ external Ġinterface ĠI Subscription Request Ġ{ ĊĠĠĠ Ġvar Ġtopic : ĠString ĊĠĠĠ Ġvar Ġq os : ĠAny ĊĠĠĠ Ġvar Ġnl : ĠBoolean ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally ĊĠĠĠ Ġvar Ġrap : ĠBoolean ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally ĊĠĠĠ Ġvar Ġrh : ĠNumber ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally Ċ } Ċ Ċ external Ġinterface Ġ` T $ 0 ` Ġ{ ĊĠĠĠ Ġvar Ġq os : ĠAny ĊĠĠĠ Ġvar Ġnl : ĠBoolean ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally ĊĠĠĠ Ġvar Ġrap : ĠBoolean ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally ĊĠĠĠ Ġvar Ġrh : ĠNumber ? ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġdefined Ex tern ally ĊĠĠĠĠĠĠĠ Ġset ( value ) Ġ= Ġdefined Ex tern ally Ċ } Ċ Ċ external Ġinterface ĠI Subscription Map Ġ{ Ċ Ċ } Ċ Ċ @ Suppress (" NOTH ING _ TO _ INLINE ") Ċ inline Ġoperator Ġfun ĠI Subscription Map . get ( topic : ĠString ): Ġ` T $ 0 `? Ġ= Ġas Dynamic ()[ topic ] Ċ Ċ @ Suppress (" NOTH ING _ TO _ INLINE ") Ċ inline Ġoperator Ġfun ĠI Subscription Map . set ( topic : ĠString , Ġvalue : Ġ` T $ 0 `) Ġ{ ĊĠĠĠ Ġas Dynamic ()[ topic ] Ġ= Ġvalue Ċ } Ċ Ċ type alias ĠClient Subscribe Callback Ġ= Ġ( err : ĠError , Ġgranted : ĠArray < IS ub scription Grant >) Ġ-> ĠUnit Ċ Ċ type alias ĠOn Message Callback Ġ= Ġ( topic : ĠString , Ġpayload : Ġdynamic , Ġpacket : Ġdynamic ) Ġ-> ĠUnit Ċ Ċ type alias ĠOn Packet Callback Ġ= Ġ( packet : Ġdynamic ) Ġ-> ĠUnit Ċ Ċ type alias ĠOn Error Callback Ġ= Ġ( error : ĠError ) Ġ-> ĠUnit Ċ Ċ type alias ĠPacket Callback Ġ= Ġ( error : ĠError , Ġpacket : Ġdynamic ) Ġ-> ĠAny Ċ Ċ type alias ĠClose Callback Ġ= Ġ() Ġ-> ĠUnit Ċ Ċ open Ġexternal Ġclass ĠM qtt Client ( stream Builder : Ġdynamic , Ġoptions : ĠI Client Options ) Ġ{ ĊĠĠĠ Ġopen Ġvar Ġconnected : ĠBoolean ĊĠĠĠ Ġopen Ġvar Ġdisconnect ing : ĠBoolean ĊĠĠĠ Ġopen Ġvar Ġdisconnected : ĠBoolean ĊĠĠĠ Ġopen Ġvar Ġreconnect ing : ĠBoolean ĊĠĠĠ Ġopen Ġvar Ġincoming Store : ĠStore ĊĠĠĠ Ġopen Ġvar Ġoutgoing Store : ĠStore ĊĠĠĠ Ġopen Ġvar Ġoptions : ĠI Client Options ĊĠĠĠ Ġopen Ġvar Ġqueue Qo S Zero : ĠBoolean ĊĠĠĠ Ġopen Ġfun Ġon ( event : ĠString , Ġcb : Ġdynamic ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġonce ( event : ĠString Ġ/* Ġ' message ' Ġ*/, Ġcb : ĠOn Message Callback ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġonce ( event : ĠString , Ġcb : ĠOn Packet Callback ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġonce ( event : ĠString Ġ/* Ġ' error ' Ġ*/, Ġcb : ĠOn Error Callback ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġonce ( event : ĠString , Ġcb : ĠFunction < *> ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġpublish ( topic : ĠString , Ġmessage : ĠString , Ġopts : ĠI Client Publish Options , Ġcallback : ĠPacket Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġpublish ( topic : ĠString , Ġmessage : Ġdynamic , Ġopts : ĠI Client Publish Options , Ġcallback : ĠPacket Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġpublish ( topic : ĠString , Ġmessage : ĠString , Ġcallback : ĠPacket Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġpublish ( topic : ĠString , Ġmessage : Ġdynamic , Ġcallback : ĠPacket Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġsubscribe ( topic : ĠString , Ġopts : ĠI Client Subscribe Options , Ġcallback : ĠClient Subscribe Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġsubscribe ( topic : ĠArray < String >, Ġopts : ĠI Client Subscribe Options , Ġcallback : ĠClient Subscribe Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġsubscribe ( topic : ĠString , Ġcallback : ĠClient Subscribe Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġsubscribe ( topic : ĠArray < String >, Ġcallback : ĠClient Subscribe Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġsubscribe ( topic : ĠI Subscription Map , Ġcallback : ĠClient Subscribe Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġunsubscribe ( topic : ĠString , Ġopts : ĠAny Ġ= Ġdefined Ex tern ally , Ġcallback : ĠPacket Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġunsubscribe ( topic : ĠArray < String >, Ġopts : ĠAny Ġ= Ġdefined Ex tern ally , Ġcallback : ĠPacket Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġend ( force : ĠBoolean Ġ= Ġdefined Ex tern ally , Ġopts : ĠAny Ġ= Ġdefined Ex tern ally , Ġcb : ĠClose Callback Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġremove Outgoing Message ( mid : ĠNumber ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġreconnect ( opts : ĠI Client Re connect Options Ġ= Ġdefined Ex tern ally ): ĠM qtt Client Ġ/* Ġthis Ġ*/ ĊĠĠĠ Ġopen Ġfun Ġhandle Message ( packet : Ġdynamic , Ġcallback : ĠPacket Callback ) ĊĠĠĠ Ġopen Ġfun ĠgetLast MessageId (): ĠNumber Ċ } Ċ