Function mapStreamToObjectStore

jetstream/object.go:1621–1633

(js *jetStream, pushJS nats.JetStreamContext, bucket string, stream Stream)

}

func mapStreamToObjectStore(js *jetStream, pushJS nats.JetStreamContext, bucket string, stream Stream) *obs {
	info := stream.CachedInfo()

	obs := &obs{
		name:       bucket,
		js:         js,
		pushJS:     pushJS,
		streamName: info.Config.Name,
		stream:     stream,
	}

	return obs
}