Skip to content

Commit

Permalink
fix: missing subscriber, schedules and storage listener clients (#27)
Browse files Browse the repository at this point in the history
  • Loading branch information
davemooreuws authored Jun 28, 2024
1 parent 790ca49 commit c87cd17
Show file tree
Hide file tree
Showing 3 changed files with 21 additions and 0 deletions.
7 changes: 7 additions & 0 deletions lib/src/resources/bucket.dart
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,13 @@ class BucketResource extends SecureResource<BucketPermission> {
$bp.StorageListenerClient? storageListenerClient})
: super(name, client) {
_storageListenerClient = storageListenerClient;

if (storageListenerClient == null) {
_storageListenerClient = $bp.StorageListenerClient(
ClientChannelSingleton.instance.clientChannel);
} else {
_storageListenerClient = storageListenerClient;
}
}

@override
Expand Down
7 changes: 7 additions & 0 deletions lib/src/resources/schedule.dart
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
7 changes: 7 additions & 0 deletions lib/src/resources/topic.dart
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,13 @@ class Topic extends SecureResource<TopicPermission> {
{$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.
Expand Down

0 comments on commit c87cd17

Please sign in to comment.