[PubSub Api] How to create a StreamingPull that will continuously listen for messages?

[orgesballa]

I have an API that publishes messages to subscribers.

In flutter, I have a subscriber and I need to pull messages from the API every time they are published.

 String subscriptionName = 'projects/test/subscriptions/test-sub';
    pubSubClient.projects.subscriptions
        .pull(
            PullRequest.fromJson({
              "maxMessages": 1000,
            }),
            subscriptionName)
        .then((pullResponse) {
      if (pullResponse.receivedMessages != null &&
          pullResponse.receivedMessages.isNotEmpty) {
        List<String> ids = [];
        pullResponse.receivedMessages.forEach((element) {
          ids.add(element.ackId);
        });
        pubSubClient.projects.subscriptions.acknowledge(
            AcknowledgeRequest.fromJson({"ackIds": ids}), subscriptionName);
      }
    });

This works but this is run only once. In the Google Cloud API, it says to use a StreamingPull to efficiently receive messages? 

How can this be done in flutter and what other options are there? 

[kevmoo]

Not exactly sure how to run with this. I'd suggest looking at https://cloud.google.com/pubsub/docs

[stevedj]

Hi, good day Kevin Moore (@kevmoo) currently I am facing the same issue,
base on the answer above, does it mean we have to use RPC to make the StreamingPull works, or do I need to create the StreamingPullRequest class?
I have tried to double-check the code, it seems it has not been implemented yet?
Please correct me if I am wrong, or is there any timeline for when it will be implemented?

Thank you for your amazing support

[kevmoo]

Hey @stevedj – sadly, you are NOT able to do a "StreamingPull" with the REST API – which is what this is. 🤷