Created a timeout stream that will exit if no responses have been found on the underlying stream for the given duration.
Apparently the stream::chunks combinator was consuming the errors given by the new heads stream that the missed transfers block listened to. Removed that so that the timeout will trigger an error, and exit.
Created a timeout stream that will exit if no responses have been found on the underlying stream for the given duration.
Apparently the
stream::chunks
combinator was consuming the errors given by the new heads stream that the missed transfers block listened to. Removed that so that the timeout will trigger an error, and exit.TODO