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.



1031
1032
1033
1034
1035
1036
1037
1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
 
# File 'lib/mdk_protocol.rb', line 1031

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 



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

def self.AckableEvent; AckableEvent; end

.AckablePayload ⇒ Object 



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

def self.AckablePayload; AckablePayload; end

.Close ⇒ Object 



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

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 



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

def self.DecodedMessage; DecodedMessage; end

.JSONParser ⇒ Object 



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

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 



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

def self.OpenCloseSubscriber; OpenCloseSubscriber; end

.OperationalEnvironment ⇒ Object 



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

def self.OperationalEnvironment; OperationalEnvironment; end

.ProtocolError ⇒ Object 



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

def self.ProtocolError; ProtocolError; end

.Pump ⇒ Object 



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

def self.Pump; Pump; end

.SendAckableEvent ⇒ Object 



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

def self.SendAckableEvent; SendAckableEvent; end

.SendWithAcks ⇒ Object 



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

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 



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

def self.WSClient; WSClient; end

.WSClientSubscriber ⇒ Object 



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

def self.WSClientSubscriber; WSClientSubscriber; end

.WSConnected ⇒ Object 



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

def self.WSConnected; WSConnected; end

.WSSend ⇒ Object 



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

def self.WSSend; WSSend; end