start method

@override void start()

Start listening for incoming clients.

Implementation

@override
void start() {
  receivePort.listen((data) {
    if (data is SendPort) {
      var id = _uuid.v4();
      _clients[id] = data;
      data.send(MessageHandler().encodeSendPortResponseMessage(id));
    } else if (data is Map<String, Object?>) {
      var (id, method, requestId, params) =
          MessageHandler().decodeRequestMessage(data);
      var (clientId, eventName, subscriptionId, value) =
          MessageHandler().decodeRequestParams(params);

      var sp = _clients[id];
      if (sp == null) {
        // There's nobody to respond to, so don't send anything to anyone
        return;
      }

      if (method == 'publish') {
        if (eventName == null || value == null) {
          sp.send(MessageHandler().encodePublishResponseError(requestId));
        }
        var rq = _IsolatePublishRequestImpl(
            requestId, clientId, eventName, value, sp);
        _onPublish.add(rq);
      } else if (method == 'subscribe') {
        if (eventName == null) {
          sp.send(
              MessageHandler().encodeSubscriptionResponseError(requestId));
        }
        var rq = _IsolateSubscriptionRequestImpl(
            clientId, eventName, sp, requestId, _uuid);
        _onSubscribe.add(rq);
      } else if (method == 'unsubscribe') {
        if (subscriptionId == null) {
          sp.send(
              MessageHandler().encodeUnsubscriptionResponseError(requestId));
        }
        var rq = _IsolateUnsubscriptionRequestImpl(
            clientId, subscriptionId, sp, requestId);
        _onUnsubscribe.add(rq);
      } else {
        sp.send(MessageHandler()
            .encodeUnknownMethodResponseError(requestId, method));
      }
    }
  });
}