Method PushConsumer

jetstream/stream.go:159–159

PushConsumer returns an interface to an existing push consumer, allowing processing of messages. If consumer does not exist, ErrConsumerNotFound is returned. It returns ErrNotPushConsumer if the consumer is not a push consumer (deliver subject is not set).

(ctx context.Context, consumer string)

		//
		// It returns ErrNotPushConsumer if the consumer is not a push consumer (deliver subject is not set).
		PushConsumer(ctx context.Context, consumer string) (PushConsumer, error)
	}

	RawStreamMsg struct {