Module: Quark::MdkProtocol

Defined in:
lib/mdk_protocol.rb

Defined Under Namespace

Classes: AckableEvent, AckablePayload, Close, DecodedMessage, JSONParser, LamportClock, Open, OpenCloseSubscriber, OperationalEnvironment, ProtocolError, Pump, SendAckableEvent, SendWithAcks, Serializable, SharedContext, WSClient, WSClientSubscriber, WSConnected, WSSend

Class Method Summary collapse

Class Method Details

._subscriberDispatch(subscriber, message) ⇒ Object

Dispatch actor messages to a WSClientSubscriber.

Call this in onMessage to handle DecodedMessage, WSConnected and Pump messages from the WSClient.



1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
1053
1054
1055
1056
1057
1058
 
# File 'lib/mdk_protocol.rb', line 1038

def self._subscriberDispatch(subscriber, message)
    
    klass = (::Quark.quark.reflect.QuarkClass.get(::DatawireQuarkCore._getClass(message))).id
    if ((klass) == ("mdk_protocol.WSConnected"))
        connected = ::DatawireQuarkCore.cast(message) { ::Quark.mdk_protocol.WSConnected }
        subscriber.onWSConnected((connected).websock)
        return
    end
    if ((klass) == ("mdk_protocol.Pump"))
        subscriber.onPump()
        return
    end
    if ((klass) == ("mdk_protocol.DecodedMessage"))
        decoded = ::DatawireQuarkCore.cast(message) { ::Quark.mdk_protocol.DecodedMessage }
        subscriber.onMessageFromServer((decoded).message)
        return
    end


    nil
end

.AckableEvent ⇒ Object 



1715
 
# File 'lib/mdk_protocol.rb', line 1715

def self.AckableEvent; AckableEvent; end

.AckablePayload ⇒ Object 



1676
 
# File 'lib/mdk_protocol.rb', line 1676

def self.AckablePayload; AckablePayload; end

.Close ⇒ Object 



736
 
# File 'lib/mdk_protocol.rb', line 736

def self.Close; Close; end

.contains(values, value) ⇒ Object

Returns whether a list contains a given value.



18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/mdk_protocol.rb', line 18

def self.contains(values, value)
    
    idx = 0
    while ((idx) < ((values).size)) do
        if ((value) == ((values)[idx]))
            return true
        end
        idx = (idx) + (1)
    end
    return false


    nil
end

.DecodedMessage ⇒ Object 



914
 
# File 'lib/mdk_protocol.rb', line 914

def self.DecodedMessage; DecodedMessage; end

.JSONParser ⇒ Object 



1213
 
# File 'lib/mdk_protocol.rb', line 1213

def self.JSONParser; JSONParser; end

.LamportClock ⇒ Object 



119
 
# File 'lib/mdk_protocol.rb', line 119

def self.LamportClock; LamportClock; end

.Open ⇒ Object 



555
 
# File 'lib/mdk_protocol.rb', line 555

def self.Open; Open; end

.OpenCloseSubscriber ⇒ Object 



1060
 
# File 'lib/mdk_protocol.rb', line 1060

def self.OpenCloseSubscriber; OpenCloseSubscriber; end

.OperationalEnvironment ⇒ Object 



285
 
# File 'lib/mdk_protocol.rb', line 285

def self.OperationalEnvironment; OperationalEnvironment; end

.ProtocolError ⇒ Object 



650
 
# File 'lib/mdk_protocol.rb', line 650

def self.ProtocolError; ProtocolError; end

.Pump ⇒ Object 



803
 
# File 'lib/mdk_protocol.rb', line 803

def self.Pump; Pump; end

.SendAckableEvent ⇒ Object 



1818
 
# File 'lib/mdk_protocol.rb', line 1818

def self.SendAckableEvent; SendAckableEvent; end

.SendWithAcks ⇒ Object 



1944
 
# File 'lib/mdk_protocol.rb', line 1944

def self.SendWithAcks; SendWithAcks; end

.Serializable ⇒ Object 



33
 
# File 'lib/mdk_protocol.rb', line 33

def self.Serializable; Serializable; end

.SharedContext ⇒ Object 



371
 
# File 'lib/mdk_protocol.rb', line 371

def self.SharedContext; SharedContext; end

.WSClient ⇒ Object 



1298
 
# File 'lib/mdk_protocol.rb', line 1298

def self.WSClient; WSClient; end

.WSClientSubscriber ⇒ Object 



974
 
# File 'lib/mdk_protocol.rb', line 974

def self.WSClientSubscriber; WSClientSubscriber; end

.WSConnected ⇒ Object 



854
 
# File 'lib/mdk_protocol.rb', line 854

def self.WSConnected; WSConnected; end

.WSSend ⇒ Object 



1854
 
# File 'lib/mdk_protocol.rb', line 1854

def self.WSSend; WSSend; end