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),
	))
}
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.
FirehoseWithoutReconnect functions identically to Firehose but without any reconnect attempts when errors occur .