akka/akka-stream-contrib

Issues

• ironmq connector

  #57 opened 8 years ago
  3

• The MQTT-connector generates files in the project root

  #56 opened 7 years ago
  2

• Ability to ack messages downstream from source

  #54 opened 8 years ago
  5

• FlowEnrichment stage

  #50 opened 8 years ago
  11

• Provide a sample AMQP connector

  #41 opened 8 years ago
  0

• Directory watch - added, changed, deleted files as events

  #35 opened 8 years ago
  2

• Provide "tail -f" like FileIO Source

  #34 opened 8 years ago
  0

• Add UnfoldFlow Source generator

  #32 opened 8 years ago
  3

• Do we need Accumulate

  #30 opened 8 years ago
  4

• Documentation?

  #29 opened 8 years ago
  6

• Add an AccumulateWhileUnchanged stage

  #27 opened 8 years ago
  0

• Add a retry graph factory, that works on flows

  #25 opened 8 years ago
  0

• LastElement silently recovers – should there be some way to inform about failure?

  #24 opened 8 years ago
  0

• consider add a distinct stage?

  #22 opened 8 years ago
  5

• Sample() stage

  #21 opened 8 years ago
  1

• Add PartitionWith stage

  #19 opened 8 years ago
  0

• streams: request new feature: timed sorting

  #15 opened 8 years ago
  0

• Add a deduplicate stage

  #14 opened 8 years ago
  2

• [ZipInputStreamSource] Mark ZipEntryData case class as final

  #12 opened 8 years ago
  0

• Upgrade to Akka 2.4.6

  #10 opened 8 years ago
  0

• Source for zip files

  #8 opened 8 years ago
  0

• Any interest in my ifChanged filter stage?

  #6 opened 8 years ago
  9

• Upgrade to sbt 0.13.11

  #4 opened 8 years ago
  1

• Move Accumulate and LastElement from hseeberger/akka-commons-streams here

  #3 opened 8 years ago
  8

• move akka.stream.extra.Timed here

  #2 opened 8 years ago
  2