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.



971
972
973
974
975
 
# File 'lib/mdk_protocol.rb', line 971

def initialize()
    self.__init_fields__

    nil
end

Instance Method Details

#__init_fields__ ⇒ Object 



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

def __init_fields__()
    

    nil
end

#onMessageFromServer(message) ⇒ Object

Handle an incoming decoded JSON message received from the server.

Raises:

  • (NotImplementedError) 


983
984
985
986
987
 
# File 'lib/mdk_protocol.rb', line 983

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) 


1001
1002
1003
1004
1005
 
# File 'lib/mdk_protocol.rb', line 1001

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) 


992
993
994
995
996
 
# File 'lib/mdk_protocol.rb', line 992

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

    nil
end