Pull Consumer doesn't work

[mightym]

Not sure if its not yet implemented yet or a bug: the pull consumer doesn't work as there is not filter passed in (I assume :-) ) Actually it works, but your not getting any messages.
This is my test pull consumer:

class UserTestPullConsumer(JetstreamPullConsumer):
    stream_name = "users"
    subjects = [
        "users.created",
    ]
    durable_name = "users_test_pull_2"

    async def setup(self):
        return [
            operations.CreateStream(
                name=self.stream_name, subjects=self.subjects, storage="file"
            ),
        ]

    async def handle_message(self, message):
        logger.info(f"Received message via Pull Consumer: {message.data}")

It gets setup. Is available on Nats. But doesn't receive any messages.

Here is how I fixed it quick and dirty:

c227622

Also there is a typo:

10fbc30