/parityakkastreams

A client for Parity using Akka-streams

Primary LanguageScalaApache License 2.0Apache-2.0

parityakkastreams

A client for Parity using Akka-streams

PMD source for parity with an optional flow to convert PMD events to MarketListner events.

###Usage example

PMDSource(settings = s, bufferSize = 10)
  .via(ParityOrderBookReconstructionFlow())
  .runWith(Sink.foreach(println(_)))

###TODO:

  1. Make PMD Source more robust to failures and configurable
  2. Make a source AND a sink to support POE