Packages

polyn

0.6.4
0.6.5 0.6.4 0.6.3 0.6.1 0.6.0 0.5.0 0.4.0 0.3.1 0.3.0 0.2.0 0.1.3 0.1.2 0.1.1 0.1.0

Polyn framework for maintaining consistent event-based messages

HexDocs

Current section

Files

Jump to
Readme
14 Versions
7 Dependencies
Dependants
Files
Activity
polyn lib jetstream pull_consumer jetstream_pull_consumer.ex
Raw

lib/jetstream/pull_consumer/jetstream_pull_consumer.ex 

defmodule Polyn.Jetstream.PullConsumer do

  # Real Jetstream PullConsumer for production

  # This exists to ensure we don't mock things we don't "own"

  @moduledoc false



  @behaviour Polyn.Jetstream.PullConsumerBehaviour



  defdelegate start_link(module, init_arg, options \\ []), to: Jetstream.PullConsumer

  defdelegate start(module, init_arg, options \\ []), to: Jetstream.PullConsumer

  defdelegate close(consumer), to: Jetstream.PullConsumer

end