MCPcopy Create free account
hub / github.com/apache/pulsar-client-go / Topic

Method Topic

pulsar/reader_impl.go:157–159  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

155}
156
157func (r *reader) Topic() string {
158 return r.c.topic
159}
160
161func (r *reader) Next(ctx context.Context) (Message, error) {
162 for {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected