search

ScalaConsultants / reactive-rabbit

Reactive Streams driver for AMQP protocol. Powered by RabbitMQ library.
Apache License 2.0
184 stars 40 forks source link

Fixing #7 using STM protected buffer and thread running flag #29

Closed LGLO closed 8 years ago

LGLO commented 8 years ago

Solution is quite fat (like one for #6). Ensuring that there will be at most on Future that is pushing elements downstream from queue.

LGLO commented 8 years ago

Apparently there is some bug regarding rule 1.03. I'm going to reimplement it from master.