-
public final class StreamComponentProviderOptional overrides for internal components used by StreamClient.
All fields default to
null, meaning the factory creates default instances. Provide a non-null value to replace a specific component — useful for sharing instances across product layers or injecting custom implementations.// Share a single-flight processor between core and product API layer val singleFlight = StreamSingleFlightProcessor(scope) val client = StreamClient( ..., components = StreamComponentProvider( singleFlight = singleFlight, ), ) val productApi = MyProductApi(singleFlight) // same instance
-
-
Field Summary
Fields Modifier and Type Field Description private final StreamLoggerProviderlogProviderprivate final StreamSingleFlightProcessorsingleFlightprivate final StreamSerialProcessingQueueserialQueueprivate final StreamTokenManagertokenManagerprivate final StreamConnectionIdHolderconnectionIdHolderprivate final StreamWebSocketFactorysocketFactoryprivate final StreamEventAggregator<?>eventAggregatorprivate final StreamHealthMonitorhealthMonitorprivate final StreamNetworkMonitornetworkMonitorprivate final StreamLifecycleMonitorlifecycleMonitorprivate final StreamConnectionRecoveryEvaluatorconnectionRecoveryEvaluatorprivate final StreamSubscriptionManager<StreamClientListener>clientSubscriptionManagerprivate final StreamAndroidComponentsProviderandroidComponentsProviderprivate final StreamTelemetrytelemetry
-
Constructor Summary
Constructors Constructor Description StreamComponentProvider(StreamLoggerProvider logProvider, StreamSingleFlightProcessor singleFlight, StreamSerialProcessingQueue serialQueue, StreamTokenManager tokenManager, StreamConnectionIdHolder connectionIdHolder, StreamWebSocketFactory socketFactory, StreamEventAggregator<?> eventAggregator, StreamHealthMonitor healthMonitor, StreamNetworkMonitor networkMonitor, StreamLifecycleMonitor lifecycleMonitor, StreamConnectionRecoveryEvaluator connectionRecoveryEvaluator, StreamSubscriptionManager<StreamClientListener> clientSubscriptionManager, StreamAndroidComponentsProvider androidComponentsProvider, StreamTelemetry telemetry)
-
Method Summary
Modifier and Type Method Description final StreamLoggerProvidergetLogProvider()final StreamSingleFlightProcessorgetSingleFlight()final StreamSerialProcessingQueuegetSerialQueue()final StreamTokenManagergetTokenManager()final StreamConnectionIdHoldergetConnectionIdHolder()final StreamWebSocketFactorygetSocketFactory()final StreamEventAggregator<?>getEventAggregator()final StreamHealthMonitorgetHealthMonitor()final StreamNetworkMonitorgetNetworkMonitor()final StreamLifecycleMonitorgetLifecycleMonitor()final StreamConnectionRecoveryEvaluatorgetConnectionRecoveryEvaluator()final StreamSubscriptionManager<StreamClientListener>getClientSubscriptionManager()final StreamAndroidComponentsProvidergetAndroidComponentsProvider()final StreamTelemetrygetTelemetry()-
-
Constructor Detail
-
StreamComponentProvider
StreamComponentProvider(StreamLoggerProvider logProvider, StreamSingleFlightProcessor singleFlight, StreamSerialProcessingQueue serialQueue, StreamTokenManager tokenManager, StreamConnectionIdHolder connectionIdHolder, StreamWebSocketFactory socketFactory, StreamEventAggregator<?> eventAggregator, StreamHealthMonitor healthMonitor, StreamNetworkMonitor networkMonitor, StreamLifecycleMonitor lifecycleMonitor, StreamConnectionRecoveryEvaluator connectionRecoveryEvaluator, StreamSubscriptionManager<StreamClientListener> clientSubscriptionManager, StreamAndroidComponentsProvider androidComponentsProvider, StreamTelemetry telemetry)
- Parameters:
logProvider- Logger provider used to create tagged loggers for internal components.singleFlight- Request deduplication processor.serialQueue- Serial processing queue for ordered execution.tokenManager- Token lifecycle manager.connectionIdHolder- Connection ID storage.socketFactory- WebSocket factory.eventAggregator- WebSocket event aggregator.healthMonitor- Connection health monitor.networkMonitor- Network connectivity monitor.lifecycleMonitor- App lifecycle monitor.connectionRecoveryEvaluator- Reconnection heuristics evaluator.clientSubscriptionManager- Socket-level listener registry.androidComponentsProvider- Android system service provider.telemetry- Telemetry engine.
-
-
Method Detail
-
getLogProvider
final StreamLoggerProvider getLogProvider()
-
getSingleFlight
final StreamSingleFlightProcessor getSingleFlight()
-
getSerialQueue
final StreamSerialProcessingQueue getSerialQueue()
-
getTokenManager
final StreamTokenManager getTokenManager()
-
getConnectionIdHolder
final StreamConnectionIdHolder getConnectionIdHolder()
-
getSocketFactory
final StreamWebSocketFactory getSocketFactory()
-
getEventAggregator
final StreamEventAggregator<?> getEventAggregator()
-
getHealthMonitor
final StreamHealthMonitor getHealthMonitor()
-
getNetworkMonitor
final StreamNetworkMonitor getNetworkMonitor()
-
getLifecycleMonitor
final StreamLifecycleMonitor getLifecycleMonitor()
-
getConnectionRecoveryEvaluator
final StreamConnectionRecoveryEvaluator getConnectionRecoveryEvaluator()
-
getClientSubscriptionManager
final StreamSubscriptionManager<StreamClientListener> getClientSubscriptionManager()
-
getAndroidComponentsProvider
final StreamAndroidComponentsProvider getAndroidComponentsProvider()
-
getTelemetry
final StreamTelemetry getTelemetry()
-
-
-
-