typescript - On error swap to another observable after atleast one successful response -


i'm using observables of rxjs communicate device accessible on http. http-calls started before device online, therefore calls can fail @ beginning. @ point device online, update started , progress polled periodically. @ end of update device has restart , afterwards provide progress on different url.

now want map behaviour rxjs:

successfulcall: boolean = false;    testget() {     return observable.timer(0, 1000)       .concatmap(() => this.http.get(this.url))       .map(response => {         let result: string = string.fromcharcode.apply(null, new uint16array(response.arraybuffer()));         this.successfulcall = true;         return result;       })       .timeout(2000)       .retrywhen(errors => {          if (this.successfulcall) {           return observable.throw("offline");         }         else {           return errors.delay(2000);         }        })       .onerrorresumenext(this.observabletwo);

my idea use retrywhen switch, can chose other observable. second observable never started, first 1 called. dependent on device status (online or offline) either receive timeouts or valid answers , calls continue. know exception in normal control flow not pretty idea.

i made little flowchart visualize idea, because imagine description of problem complicated.

wassuccessful have initialized false , processing of observable results not shown

flowchart of observable

also other (maybe prettier/better) approaches okay, want solve problem , not have insist on approch.

so want poll remote device until comes online , after initial bootup has succeeded continue update process after goes offline , want start polling again. 

// mock implementation of polling until succes  var attempts = 0;  function startup() {    attempts++;    if(attempts < 10) {      return rx.observable.throw(new error('not booted yet'));    }    attempts = 0;    return rx.observable.of('remote device online');  }    const bootuppollingsource = rx.observable.of('')    .concatmap(_ =>        rx.observable.defer(() => startup())       .do(null, err => console.log('[debug] bootup err:' + err.message))       .retrywhen(attempts => attempts.delay(100))    );    const regularoperationssource = rx.observable.from(['starting update','...','...'])    .concat(rx.observable.throw(new error('device rebooting')))    .catch(err => bootuppollingsource)    bootuppollingsource    .concat(regularoperationssource)    .subscribe(console.log, console.log, () => console.log('completed'));
    <script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.0.3/rx.js"></script>


Comments

Post a Comment

Popular posts from this blog

asynchronous - C# WinSCP .NET assembly: How to upload multiple files asynchronously -

i using winscp .net assembly uploading files. want upload multiple files asynchronous way. have created method works single upload. public class uploadingdata { private sessionoptions _sessionoptions; private session _session; //connection etc private void onconnected() { foreach (var fileinfo in localfileslist) { var task = task.factory.startnew(() => uploadfilesasync(fileinfo)); } } private async task uploadfilesasync(string file) { string remotefilepath = _session.translatelocalpathtoremote(file, @"/", "/test_data_upload"); var uploading = _session.putfiles(file, remotefilepath, false); //when done await task.run(() => thread.sleep(1000)); } } please suggest me correct way. thanks you can use backgroundworker class this: string[] images = new string[50]; foreach (var path in images) { backgroundworker
Read more

aws api gateway - SerializationException in posting new Records via Dynamodb Proxy Service in API -

i getting "__type": "com.amazon.coral.service#serializationexception" as reply in postman & in test console in api gateway trying post record directly dynamodb using api proxy services.. referring aws article - https://aws.amazon.com/blogs/compute/using-amazon-api-gateway-as-a-proxy-for-dynamodb/ here's mapping { "tablename": "tablenamegoeshere", "item": { "id" : "$context.requestid" "eventname" : "$input.path('$.eventname')", "timestamp" : $input.path('$.timestamp'), "answers": "$util.parsejson($input.path('$.answers'))" } } update: did asked ... , worked if try add array of json objects gives me above same error - here's trying now. please - couldnt find on google well #set($inputroot = $input.path('$')) { "tablename": "answer", "item": {
Read more

asp.net - Problems sending emails from forum -

i have been redesigning site has message board, has been written guy looked after site. it has few problems , written in .asp , uses .mdb files database. you can see whole thing here . feel free post if helps, test thing have set using original files , new database. the basic problem when posts message, supposed email sent them, have posted it. when replies, originator supposed message, replier has been posted. i’d have thought @ point in process there should script/file in postmessage.asp? the postmessage.asp page below. <% option explicit %> <!-- #include virtual="common/adovbs.inc" --> <html> <head> <meta http-equiv="content-type" content="text/html; charset=windows-1252"> <meta name="generator" content="microsoft frontpage 4.0"> <meta name="progid" content="frontpage.editor.document"> <title>new page 2</title> <base target="_self"
Read more