Skip to content

Instantly share code, notes, and snippets.

@ssougnez

ssougnez/wamr-97.ts

Last active Mar 13, 2021
Embed
What would you like to do?
import { Observable } from 'rxjs';
import { retry } from 'rxjs/operators';
const observable = new Observable<number>(observer => {
let x = 0;
const interval = setInterval(() => {
if (x === 5 && Math.random() < .5) {
observer.error('Oops');
}
else {
observer.next(x++);
}
}, 1000);
return {
unsubscribe: () => clearInterval(interval)
}
});
observable
.pipe(
retry(1)
)
.subscribe({
next: x => console.log(`${x} received`),
complete: () => console.log('Completed'),
error: err => console.warn(err)
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment