akka/akka-stream-contrib

Issues

• Add switch/switchMap

  #114 opened 7 years ago by nadavwr
  3

• Make the valve state inspection always complete

  #119 opened 2 years ago by johanandren
  0

• Why no more releases?

  #187 opened 4 years ago by lostiniceland
  1

• Add Java API for Retry with examples

  #113 opened 7 years ago by synox
  3

• Shared valve switch

  #186 opened 4 years ago by harpocrates
  1

• Migrate from travis.org to travis.com

  #184 opened 4 years ago by ignasi35
  1

• Publish artifacts for scala 2.13

  #147 opened 5 years ago by cchantep
  2

• Support for sorting fan-in shape with more than two upstreams

  #174 opened 5 years ago by andreas-schroeder
  0

• Publish API documentation to doc.akka.io

  #173 opened 5 years ago by raboof
  7

• TokenThrottle can fail to complete and doesn't consistently pre-fetch tokens

  #168 opened 5 years ago by andreas-schroeder
  0

• Introduce Token Throttle

  #166 opened 5 years ago by andreas-schroeder
  3

• Remove PassThroughFlow which is not superseded by FlowWithContext

  #165 opened 5 years ago by 2m
  0

• PassThroughFlow limits the rate of the inner processingFlow

  #160 opened 5 years ago by bchazalet
  5

• Remove unrelated tools

  #158 opened 5 years ago by ennru
  0

• Publishing from Travis fails

  #156 opened 5 years ago by ennru
  0

• Automate release and host scaladoc

  #98 opened 5 years ago by 2m
  1

• Add maxNumber and maxTime to AccumulateWhileUnchanged

  #144 opened 6 years ago by LysanderGG
  0

• Any interest in integrating actor into a Flow though a GraphStage?

  #140 opened 6 years ago by fmeeuw
  3

• FileTailSource and DirectoryChanges have moved to Alpakka

  #132 opened 6 years ago by ennru
  1

• replace scala.Either in PartitionWith Java API

  #135 opened 6 years ago by laszlovandenhoek
  3

• UnfoldFlowSpecAutoFusingOn failed

  #108 opened 6 years ago by raboof
  9

• Release 0.9

  #123 opened 6 years ago by milandesai
  1

• Sources for requesting from paged APIs

  #93 opened 6 years ago by dpfeiffer
  4

• Retry concat should process multiple elements concurrently

  #86 opened 7 years ago by matankdr
  1

• IntervalBasedRateLimiter should limit rate of messages when frequency is very high (50 000 elements per 1 000ms) failed: 4 was not equal to 3

  #125 opened 7 years ago by raboof
  0

• Alternative way of defining Graph Stages

  #122 opened 7 years ago by jorkey
  3

• Add an interval-based rate limiter

  #101 opened 7 years ago by mkubala
  0

• Facility to obtain the state of a valve's switch

  #116 opened 7 years ago by zaharidichev
  1

• DelayFlow stage with flexible delay management

  #89 opened 7 years ago by manonthegithub
  1

• FAILED: TimeWindow flow test fails occasionally

  #104 opened 7 years ago by manonthegithub
  1

• NPE using assertAllStagesStopped

  #111 opened 7 years ago by cchantep
  6

• LazyBroadcastHub

  #110 opened 7 years ago by jroper
  4

• FAILED: Pulse Stage should emit the first available element

  #105 opened 7 years ago by manonthegithub
  7

• FAILED: A bunch of tests failed in ValveSpec

  #106 opened 7 years ago by manonthegithub
  4

• An initially-opened Pulse Stage should emit the first available element

  #109 opened 7 years ago by raboof
  0

• Running graph twice is not safe.

  #100 opened 7 years ago by tom-andersen
  2

• doc: list of external integration components

  #59 opened 7 years ago by patriknw
  1

• Java API for the streaming XML parser

  #65 opened 7 years ago by johanandren
  1

• Valve component pulls port (valve.in) twice

  #84 opened 8 years ago by samidalouche
  2

• remove all connectors as they moved to alpakka

  #78 opened 8 years ago by johanandren
  2

• contrib sub-project depends on akka-stream-testkit in Compile configuration

  #82 opened 8 years ago by hseeberger
  10

• Build and release against Scala 2.12

  #67 opened 8 years ago by hseeberger
  6

• Issue with Valve Component and completed Graph

  #80 opened 8 years ago by fchaillou
  0

• AWS S3 integration

  #75 opened 8 years ago by agolubev
  3

• FlowDeathPact

  #74 opened 8 years ago by ktoso
  6

• Failed CassandraSourceSpec

  #70 opened 8 years ago by 2m
  2

• Question on how cassandra connector works

  #68 opened 8 years ago by hardvain
  4

• MqttSource doesn't release backpressure semaphore for fast downstream

  #62 opened 8 years ago by tkawachi
  0

• Add Debouncing

  #61 opened 8 years ago by joearasin
  20

• consider adding a simpler API for retrying simple flows

  #58 opened 8 years ago by hochgi
  0