Class: Quark::MdkProtocol::WSClientSubscriber

Inherits:
DatawireQuarkCore::QuarkObject show all
Extended by:
DatawireQuarkCore::Static
Defined in:
lib/mdk_protocol.rb

Overview

Higher-level interface for subscribers, to be utilized with _subscriberDispatch.

Constant Summary

Constants included from DatawireQuarkCore::Static

DatawireQuarkCore::Static::Unassigned

Instance Method Summary collapse

Methods included from DatawireQuarkCore::Static

_lazy_statics, static, unlazy_statics

Methods inherited from DatawireQuarkCore::QuarkObject

#to_s

Constructor Details

#initialize ⇒ WSClientSubscriber

Returns a new instance of WSClientSubscriber.



978
979
980
981
982
 
# File 'lib/mdk_protocol.rb', line 978

def initialize()
    self.__init_fields__

    nil
end

Instance Method Details

#__init_fields__ ⇒ Object 



1014
1015
1016
1017
1018
 
# File 'lib/mdk_protocol.rb', line 1014

def __init_fields__()
    

    nil
end

#onMessageFromServer(message) ⇒ Object

Handle an incoming decoded JSON message received from the server.

Raises:

  • (NotImplementedError) 


990
991
992
993
994
 
# File 'lib/mdk_protocol.rb', line 990

def onMessageFromServer(message)
    raise NotImplementedError, '`WSClientSubscriber.onMessageFromServer` is an abstract method'

    nil
end

#onPump ⇒ Object

Called when the WSClient notifies the subscriber it can send data.

Raises:

  • (NotImplementedError) 


1008
1009
1010
1011
1012
 
# File 'lib/mdk_protocol.rb', line 1008

def onPump()
    raise NotImplementedError, '`WSClientSubscriber.onPump` is an abstract method'

    nil
end

#onWSConnected(websocket) ⇒ Object

Called with WebSocket actor when the WSClient connects to the server.

Raises:

  • (NotImplementedError) 


999
1000
1001
1002
1003
 
# File 'lib/mdk_protocol.rb', line 999

def onWSConnected(websocket)
    raise NotImplementedError, '`WSClientSubscriber.onWSConnected` is an abstract method'

    nil
end