class AnyCable::BroadcastAdapters::Nats
def initialize(
def initialize( channel: AnyCable.config.nats_channel, **options ) options = AnyCable.config.to_nats_params.merge(options) @nats_conn = ::NATS.connect(nil, options) setup_listeners(nats_conn) @channel = channel end