A modern programming language that makes developers happier.

kotlinlang

how do I poll with Rx? I want to keep querying an endpoint until its content include some value, and I want to be querying it 2 seconds apart for example until that result is found

I haven't actually used Rx productively in a while, but I would assume something like:

```interval(2.seconds)
  .flatMap {
     // create observable that queries endpoint
   }
   .takeUntil {
     // it has expected content
   }```

actually inside `takeUntil`  i get back an Observer&lt;in Transaction&gt;

I cannot check whether i have the value im looking for or not until I’ve subscribed and it comes back

oh I can give the takeUntil the value type im expecting and check that

but who will give it magically to takeUntil?

you can use filter - take1 or other variant