Sha256: 9b1cf464d043d8a905451e9dab1b211a69b5a6dbf149e5fa28a288ea5286c768

Contents?: true

Size: 661 Bytes

Versions: 3

Compression:

Stored size: 661 Bytes

Contents

module NATS
  class JetStream
    module Msg
      module AckMethods
        def ack: (**Hash[Symbol, untyped]) -> NATS::JetStream::PubAck

        def ack_sync: (**Hash[Symbol, untyped]) -> NATS::JetStream::PubAck

        def nak: (**Hash[Symbol, untyped]) -> NATS::JetStream::PubAck

        def term: (**Hash[Symbol, untyped]) -> NATS::JetStream::PubAck

        def in_progress: (**Hash[Symbol, untyped]) -> NATS::JetStream::PubAck

        def metadata: () -> NATS::JetStream::Msg::Metadata

        private

        def ensure_is_acked_once!: () -> void

        def parse_metadata: (String) -> NATS::JetStream::Msg::Metadata
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
nats-pure-2.5.0 sig/nats/io/jetstream/msg/ack_methods.rbs
nats-pure-2.4.0 sig/nats/io/jetstream/msg/ack_methods.rbs
nats-pure-2.3.0 sig/nats/io/jetstream/msg/ack_methods.rbs