consumer/async.go
func (c *Consumer) FirehoseWithoutReconnect(
	subscriptionId string,
	authToken string,
) (<-chan *events.Envelope, <-chan error) {
	return c.firehose(newFirehose(
		subscriptionId,
		authToken,
		WithRetry(false),
	))
}
func (c *Consumer) FirehoseWithoutReconnect(
	subscriptionId string,
	authToken string,
) (<-chan *events.Envelope, <-chan error) {
	return c.firehose(newFirehose(
		subscriptionId,
		authToken,
		WithRetry(false),
	))
}
// FirehoseWithoutReconnect functions identically to Firehose but without any
// reconnect attempts when errors occur.