Spans not appearing in telemetry for MQTT message handling with NodeRuntime.runMain

    const addMessageHandler = (client, handler) => {
      return Effect.sync(() => {

        client.on("message", (topic, payload, packet) => {
          const effect = Effect.gen(function* () {
            // ... 
            yield* handler(topic, payload, packet);
          }).pipe(Effect.withSpan("MqttConnService:onMessage"));

          Effect.runFork(effect);
        });
      });
    };

yield* mqttService.addMessageHandler(client, messageHandler);