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.



985
986
987
988
989
 
# File 'lib/mdk_protocol.rb', line 985

def initialize()
    self.__init_fields__

    nil
end

Instance Method Details

#__init_fields__ ⇒ Object 



1021
1022
1023
1024
1025
 
# File 'lib/mdk_protocol.rb', line 1021

def __init_fields__()
    

    nil
end

#onMessageFromServer(message) ⇒ Object

Handle an incoming decoded JSON message received from the server.

Raises:

  • (NotImplementedError) 


997
998
999
1000
1001
 
# File 'lib/mdk_protocol.rb', line 997

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) 


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

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) 


1006
1007
1008
1009
1010
 
# File 'lib/mdk_protocol.rb', line 1006

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

    nil
end