struct NATS::JetStream::StreamSource::Consumer

Overview

The consumer the server uses to read from the source stream

Defined in:

jetstream/stream_source.cr

Constructors

Instance Method Summary

Constructor methods inherited from struct NATS::JetStream::Entity

new(pull : JSON::PullParser)
new(*, __pull_for_json_serializable pull : JSON::PullParser)
new

Constructor Detail

def self.new(pull : JSON::PullParser) #

The consumer the server uses to read from the source stream


[View source]
def self.new(*, name : Nil | String = nil, deliver_subject : Nil | String = nil) #

[View source]

Instance Method Detail

def deliver_subject : String | Nil #

[View source]
def name : String | Nil #

[View source]