Questions tagged [monifu]

Concurrent programming library for Scala. Use this tag with questions about programming with Monifu.

Monifu is an extension to 's standard library for and . It targets both the and .

Useful Links:

4 questions
2
votes
1 answer

Scala Rx Observable using Monifu

I'm just trying to grasp the concepts between a hot and a cold observable and trying out the Monifu library. My understanding is that the following code should result in only one of the subscriber getting the events emitted by the Observable, but it…
joesan
  • 13,963
  • 27
  • 95
  • 232
2
votes
1 answer

Subject that emits events to subscribers in specific order with back-pressure

Imagine a pipe of subscribers that you emit event to and it visits one subscriber after another. Having a PublishSubject and x subscribers/observables. Normally events are emitted to observers in a specific order but simultaneously regardless of…
lisak
  • 21,611
  • 40
  • 152
  • 243
1
vote
3 answers

How to globally order multiple ordered observables in Monix

Suppose I have multiple iterators that are ordered. If I wanted to merge these iterators while globally ordering them (e.g. [(1,3,4), (2,4,5)] -> [1,2,3,4,4,5]) using monix how would I do it?
BasilTomato
  • 1,071
  • 1
  • 8
  • 14
1
vote
1 answer

Is Javascript event loop task queue overflow possible?

Is it possible to define a boundary that shouldn't be crossed for the application to scale well regarding task scheduling (over)use? Questions : Is there a certain cost of doing setTimeout? Let say 0.1ms or CPU time? There is certainly order of…
lisak
  • 21,611
  • 40
  • 152
  • 243