StackOverflow Questions for Tag: monix

Giuliano De Sabata

Reputation: 33

Reactive streams (monix) operator combination for buffering for a timespan with overlapping elements

scalaobservablerx-javareactive-programmingmonix

Score: 1

Answers: 2

Ryan Stull

Reputation: 21

Create multicast Monix Observable that can restart when new subscriber subscribes

scalaobservablereactive-programmingscala-3monix

Score: 2

Answers: 1

Nazil Khan

Reputation: 147

Making two independent service calls from Monix Observable

scalareactive-programmingmonix

Score: 1

Answers: 0

it2901

Reputation: 89

Creating a warm Observable and dealing with unexpected behavior - Monix, Scala, Cask

scalaserverobservablemonix

Score: 1

Answers: 0

WeiChing 林煒清

Reputation: 4469

What is lost after converting Monix `Task` to Cats `IO`?

multithreadingscalafunctional-programmingscala-catsmonix

Score: 10

Answers: 1

sheldonzy

Reputation: 5961

Converting monix.eval.Task to scala.concurrent.Future

scalaasynchronousfuturemonix

Score: 1

Answers: 1

BasilTomato

Reputation: 1071

How to globally order multiple ordered observables in Monix

scalareactive-programmingmonifumonix

Score: 1

Answers: 2

Thomas

Reputation: 6196

Does back pressure with subject and multicast observable?

rxjsreactivexmonix

Score: 1

Answers: 0

Zeke1999

Reputation: 35

Why are results ordered in this Task.parSequenceUnordered? Monix

scalamonix

Score: 1

Answers: 2

Zeke1999

Reputation: 35

Monix - Why does this future complete?

scalamonix

Score: 1

Answers: 1

Jelly

Reputation: 1298

Scala Monix: Collect data from Observer.foldLeft

scalareactive-programmingmonix

Score: 0

Answers: 1

Kamil Kloch

Reputation: 333

Monix Coeval.memoize blows the stack

scalamonix

Score: 2

Answers: 2

Dyin

Reputation: 5366

Opportunistic, partially and asyncronously pre-processing of a syncronously processing iterator

scalaasynchronousfuturescala-catsmonix

Score: 0

Answers: 2

WilQu

Reputation: 7383

How to create an Observable from a non thread-safe iterator?

multithreadingscalaiteratorobservablemonix

Score: 2

Answers: 0

Sourabh

Reputation: 119

Ensuring order of execution in Task.sequence for Monix

scalaasynchronousreactive-programmingmonix

Score: 1

Answers: 0

user2185573

Reputation:

Error Handling on Monix parallel tasks (using parMap)

scalaasynchronousmonix

Score: 2

Answers: 1

Kamil Kloch

Reputation: 333

Scala diverging implicit expansion for cats.effect.Timer when using monix TaskApp

scalaimplicitmonix

Score: 1

Answers: 1

Karthik P

Reputation: 481

Is there a simple way to convert Option[Task[T]] to Task[Option[T]]?

scalafunctional-programmingreactive-programmingziomonix

Score: 3

Answers: 1

Thomas

Reputation: 6196

How is the Partially-Applied Type used in this case Task.Create?

scalamonix

Score: 1

Answers: 0

joesan

Reputation: 15385

Dealing and Sharing State with a Monix Task in a Recursive Loop

scalamonix

Score: 0

Answers: 0

PreviousPage 1Next