Method which returns a Stream, based from the error.
final Stream<S> Function(Object error) recoveryFn;