sendMessage method

  1. @override
FutureOr<void> sendMessage(
  1. M message
)
override

Implementation

@override
FutureOr<void> sendMessage(M message) {
  if (_disposed || !_started || paused || !_publishing) return null;
  connection.publishMessage(
    streamName: config.name,
    fromEndpointId: endpointId,
    payload: encodeForWire(message),
  );
  return null;
}