chore: fix missing @internal annotations (#993)

Fix missing @internal annotations

Author: hiroshihorie

.changes/mark-internal-symbols

@@ -0,0 +1 @@
+patch type="chore" "Mark internal-only symbols with @internal"

example/lib/pages/prejoin.dart

@@ -268,7 +268,7 @@ class _PreJoinPageState extends State<PreJoinPage> {
       if (!context.mounted) return;
       await Navigator.push<void>(
         context,
-        MaterialPageRoute(builder: (_) => RoomPage(room, listener)),
+        MaterialPageRoute(builder: (_) => RoomPage(room, listener, fastConnection: true)),
       );
     } catch (error) {
       print('Could not connect $error');

example/lib/pages/room.dart

@@ -14,10 +14,12 @@ import '../widgets/participant_info.dart';
 class RoomPage extends StatefulWidget {
   final Room room;
   final EventsListener<RoomEvent> listener;
+  final bool fastConnection;
 
   const RoomPage(
     this.room,
     this.listener, {
+    this.fastConnection = false,
     super.key,
   });
 
@@ -28,7 +30,7 @@ class RoomPage extends StatefulWidget {
 class _RoomPageState extends State<RoomPage> {
   List<ParticipantTrack> participantTracks = [];
   EventsListener<RoomEvent> get _listener => widget.listener;
-  bool get fastConnection => widget.room.engine.fastConnectOptions != null;
+  bool get fastConnection => widget.fastConnection;
   @override
   void initState() {
     super.initState();

lib/src/core/engine.dart

@@ -68,6 +68,7 @@ const defaultRetryDelaysInMs = [
 class Engine extends Disposable with EventsEmittable<EngineEvent> {
   static const _lossyDCLabel = '_lossy';
   static const _reliableDCLabel = '_reliable';
+  @internal
   final SignalClient signalClient;
 
   final PeerConnectionCreate _peerConnectionCreate;
@@ -978,6 +979,7 @@ class Engine extends Disposable with EventsEmittable<EngineEvent> {
     }
   }
 
+  @internal
   Future<void> handleReconnect(ClientDisconnectReason reason) async {
     if (_isClosed) {
       logger.fine('handleReconnect: engine is closed, skip');

lib/src/core/room.dart

@@ -109,6 +109,7 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
   UnmodifiableListView<Participant> get activeSpeakers => UnmodifiableListView<Participant>(_activeSpeakers);
   List<Participant> _activeSpeakers = [];
 
+  @internal
   final Engine engine;
   // suppport for multiple event listeners
   late final EventsListener<EngineEvent> _engineListener;
@@ -1293,6 +1294,7 @@ extension DataStreamRoomMethods on Room {
     _byteStreamHandlers.remove(topic);
   }
 
+  @internal
   Future<void> handleStreamHeader(
       lk_models.DataStream_Header streamHeader, String participantIdentity, EncryptionType encryptionType) async {
     if (streamHeader.hasByteHeader()) {
@@ -1382,6 +1384,7 @@ extension DataStreamRoomMethods on Room {
     }
   }
 
+  @internal
   void handleStreamChunk(lk_models.DataStream_Chunk chunk, EncryptionType encryptionType) {
     final fileBuffer = _byteStreamControllers[chunk.streamId];
 
@@ -1419,6 +1422,7 @@ extension DataStreamRoomMethods on Room {
     }
   }
 
+  @internal
   Future<void> handleStreamTrailer(lk_models.DataStream_Trailer trailer, EncryptionType encryptionType) async {
     final textBuffer = _textStreamControllers[trailer.streamId];
     if (textBuffer != null) {
@@ -1464,6 +1468,7 @@ extension DataStreamRoomMethods on Room {
     }
   }
 
+  @internal
   Future<void> validateParticipantHasNoActiveDataStreams(String participantIdentity) async {
     // Terminate any in flight data stream receives from the given participant
     final textStreamsBeingSentByDisconnectingParticipant = _textStreamControllers.values

lib/src/participant/local.dart

@@ -996,6 +996,7 @@ extension RPCMethods on LocalParticipant {
     await room.engine.sendDataPacket(packet, reliability: Reliability.reliable);
   }
 
+  @internal
   void handleIncomingRpcAck(String requestId) {
     final handler = _pendingAcks[requestId];
     if (handler != null) {
@@ -1006,6 +1007,7 @@ extension RPCMethods on LocalParticipant {
     }
   }
 
+  @internal
   void handleIncomingRpcResponse(
     String requestId,
     String? payload,
@@ -1020,6 +1022,7 @@ extension RPCMethods on LocalParticipant {
     }
   }
 
+  @internal
   Future<void> handleIncomingRpcRequest(
     String callerIdentity,
     String requestId,

lib/src/publication/track_publication.dart

@@ -86,6 +86,7 @@ abstract class TrackPublication<T extends Track> extends Disposable {
   /// True when the track is published with source [TrackSource.screenShareVideo].
   bool get isScreenShare => kind == TrackType.VIDEO && source == TrackSource.screenShareVideo;
 
+  @internal
   void updateFromInfo(lk_models.TrackInfo info) {
     // ignore: deprecated_member_use_from_same_package
     _simulcasted = info.simulcast;

lib/src/track/local/video.dart

@@ -362,6 +362,7 @@ extension LocalVideoTrackExt on LocalVideoTrack {
     return newCodecs;
   }
 
+  @internal
   Future<void> updatePublishingLayers(
     LocalTrack? track,
     List<lk_rtc.SubscribedQuality> layers,