registerByteStreamHandler method

void registerByteStreamHandler(
  1. String topic,
  2. ByteStreamHandler callback
)

Implementation

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