diff --git a/lib/src/resources/bucket.dart b/lib/src/resources/bucket.dart index cb62594..f14c269 100644 --- a/lib/src/resources/bucket.dart +++ b/lib/src/resources/bucket.dart @@ -10,6 +10,13 @@ class BucketResource extends SecureResource { $bp.StorageListenerClient? storageListenerClient}) : super(name, client) { _storageListenerClient = storageListenerClient; + + if (storageListenerClient == null) { + _storageListenerClient = $bp.StorageListenerClient( + ClientChannelSingleton.instance.clientChannel); + } else { + _storageListenerClient = storageListenerClient; + } } @override diff --git a/lib/src/resources/schedule.dart b/lib/src/resources/schedule.dart index c294702..f722614 100644 --- a/lib/src/resources/schedule.dart +++ b/lib/src/resources/schedule.dart @@ -7,6 +7,13 @@ class Schedule extends Resource { {$p.ResourcesClient? client, $sp.SchedulesClient? schedulesClient}) : super(name, client) { _schedulesClient = schedulesClient; + + if (schedulesClient == null) { + _schedulesClient = + $sp.SchedulesClient(ClientChannelSingleton.instance.clientChannel); + } else { + _schedulesClient = schedulesClient; + } } @override diff --git a/lib/src/resources/topic.dart b/lib/src/resources/topic.dart index fedbbe6..816e9d2 100644 --- a/lib/src/resources/topic.dart +++ b/lib/src/resources/topic.dart @@ -9,6 +9,13 @@ class Topic extends SecureResource { {$p.ResourcesClient? client, $tp.SubscriberClient? subscriberClient}) : super(name, client) { _subscriberClient = subscriberClient; + + if (subscriberClient == null) { + _subscriberClient = + $tp.SubscriberClient(ClientChannelSingleton.instance.clientChannel); + } else { + _subscriberClient = subscriberClient; + } } /// Register a [handler] to subscribe to messages sent to the topic.