registerTextStreamHandler method

void registerTextStreamHandler(
  1. String topic,
  2. TextStreamHandler callback
)

Implementation

void registerTextStreamHandler(String topic, TextStreamHandler callback) {
  _ensureNotReservedRpcTopic(topic);
  if (dataStreams.textStreamHandlers.containsKey(topic)) {
    throw DataStreamError(
      message: 'A text stream handler for topic "${topic}" has already been set.',
      reason: DataStreamErrorReason.HandlerAlreadyRegistered,
    );
  }
  dataStreams.registerTextStreamHandler(topic, callback);
}