java - How can we implement Observable.flatMapCompletable? -

-

for single can that:

init {     single.just("blah")             .flatmapcompletable { updatelocalization() } }  private fun updatelocalization(): completable {     return textsmanager.getcurrentlocalization()         .doonsuccess {             _localization =             logger.debug("updatelocalization:doonsuccess")         }         .tocompletable() }

and method observable.flatmapcompletable(completable)? there reason why isn't implemented in rxjava? how can implement on own?

for use completable.await() in observable.onnext:

textsmanager.eventsbus.observe()         .oftype(textsmanager.event.localizationupdated::class.java)         .doonnext { updatelocalization().await() }         .subscribe()


Comments

Post a Comment

Popular posts from this blog

jsf - "PropertyNotWritableException: Illegal Syntax for Set Operation" error when setting value in bean -

-
this question has answer here: how send form input values , invoke method in jsf bean 1 answer i error when trying send values jsf page bean. i want set values fields in bean, create airplane instance , add database. error telling me use illegal syntax setter part of bean. why error? didnt find on site helped me problem. here jsf part: <h4>add plane</h4> <c:if test="#{not empty listairplanebb.error}"> <div class="alert alert-danger"> <span class="glyphicon glyphicon-remove"></span> <h:outputtext value="#{listairplanebb.error}" /> </div> </c:if> <h:form> <table class="table"> <thead> ...
Read more

java - How to read a file created at runtime? -

-
using java 8. basically, in unit test (junit) have code: callsomecode(); asserttrue(new file(this.getclass().getresource("/img/dest/someimage.gif").getfile()).exists()); in callsomecode() , have this: inputstream = bodypart.getinputstream(); file f = new file("src/test/resources/img/dest/" + bodypart.getfilename()); //filename being someimage.gif fileoutputstream fos = new fileoutputstream(f); byte[] buf = new byte[40096]; int bytesread; while ((bytesread = is.read(buf)) != -1) fos.write(buf, 0, bytesread); fos.close(); the first time test runs, this.getclass().getresource("/img/dest/someimage.gif") returns null although file created. the second time (when file created during first test run overwritten), non-null , test passes. how make work first time? should configure special setup in intellij automatically refresh folder file created? note have basic maven structure: --src ----test ------resources as comment n...
Read more

php - Autoloader issue not returning Class -

-
problem? bootloader (autoloader) not seem working properly, or i'm missing something. here simplified code. the code below returns class "skeleton" not exist. on index.php file. index.php <?php include 'bootloader.php'; use skeleton\html\loginheader; $tool = new skeleton/html/loginheader(); bootloader.php <?php function boot($classname) { $filename = ''; $namespace = ''; // sets include path "src" directory $includepath = dirname(__file__).directory_separator.'src'; if (false !== ($lastnspos = strripos($classname, '\\'))) { $namespace = substr($classname, 0, $lastnspos); $classname = substr($classname, $lastnspos + 1); $filename = str_replace('\\', directory_separator, $namespace) . directory_separator; } $filename .= str_replace('_', directory_separator, $classname) . '.php'...
Read more