Skip to content

Commit c87cd17

Browse files
authored
fix: missing subscriber, schedules and storage listener clients (#27)
1 parent 790ca49 commit c87cd17

File tree

3 files changed

+21
-0
lines changed

3 files changed

+21
-0
lines changed

lib/src/resources/bucket.dart

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,13 @@ class BucketResource extends SecureResource<BucketPermission> {
1010
$bp.StorageListenerClient? storageListenerClient})
1111
: super(name, client) {
1212
_storageListenerClient = storageListenerClient;
13+
14+
if (storageListenerClient == null) {
15+
_storageListenerClient = $bp.StorageListenerClient(
16+
ClientChannelSingleton.instance.clientChannel);
17+
} else {
18+
_storageListenerClient = storageListenerClient;
19+
}
1320
}
1421

1522
@override

lib/src/resources/schedule.dart

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,13 @@ class Schedule extends Resource {
77
{$p.ResourcesClient? client, $sp.SchedulesClient? schedulesClient})
88
: super(name, client) {
99
_schedulesClient = schedulesClient;
10+
11+
if (schedulesClient == null) {
12+
_schedulesClient =
13+
$sp.SchedulesClient(ClientChannelSingleton.instance.clientChannel);
14+
} else {
15+
_schedulesClient = schedulesClient;
16+
}
1017
}
1118

1219
@override

lib/src/resources/topic.dart

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,13 @@ class Topic extends SecureResource<TopicPermission> {
99
{$p.ResourcesClient? client, $tp.SubscriberClient? subscriberClient})
1010
: super(name, client) {
1111
_subscriberClient = subscriberClient;
12+
13+
if (subscriberClient == null) {
14+
_subscriberClient =
15+
$tp.SubscriberClient(ClientChannelSingleton.instance.clientChannel);
16+
} else {
17+
_subscriberClient = subscriberClient;
18+
}
1219
}
1320

1421
/// Register a [handler] to subscribe to messages sent to the topic.

0 commit comments

Comments
 (0)