Contents

module NATS
  class JetStream
    module PullSubscription
      class PubAck < Struct[String | Numeric | bool]
      end

      def next_msg: (untyped) -> void

      def fetch: (Integer, Hash[Symbol, untyped]) -> Array[NATS::Msg]

      def consumer_info: (Hash[Symbol, untyped]) -> NATS::JetStream::ConsumerInfo
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
nats-pure-2.4.0	sig/nats/io/jetstream/pull_subscription.rbs
nats-pure-2.3.0	sig/nats/io/jetstream/pull_subscription.rbs