Make the SqsStream infinite

[zio]

Make the SqsStream infinite

[ghostdogpr]

I think it makes sense to have this option in addition to the existing one. To be consistent with Producer I think it would be good to mimic methods that do not fail the operation but return ErrorOrEvent[T] (defied as Either[ProducerError[T], ProducerEvent[T]]), in particular sendStreamE.

[melgenek]

I implemented the proposal and it doesn't seem to be reasonable to me any more 🙂.

Returning Either[Throwable, Message.ReadOnly] would mean that the next request to sqs follows the failed one without giving any time to the system to recover. So in my example, the dns issue can last some seconds or minutes and the stream would be flooded with Left values. This can cause performance issues, the monitoring and logging systems will be full of errors etc.

The better approach for my desire of having an infinite stream is retiring the failed stream exponentially. The code would look like

SqsStream(???, ???)
      .runDrain
      .retry(Schedule.exponential(1.second) || Schedule.spaced(4.second) )