sendStreamMessage method

Future<void> sendStreamMessage(
  1. StreamingSession session,
  2. SerializableEntity message
)

Sends an event to the client represented by the Session object.

Implementation

Future<void> sendStreamMessage(
    StreamingSession session, SerializableEntity message) async {
  var prefix = moduleName == null ? '' : '$moduleName.';

  var data = {
    'endpoint': '$prefix$name',
    'object': server.serializationManager.wrapWithClassName(message),
  };

  var payload = SerializationManager.encode(data);
  session.webSocket.add(payload);
}