dashbitco/flow

Issues

• Access previous windows

  #121 opened a year ago by kozy
  2

• Combining `Flow.shuffle/2` with `Flow.start_link/2` raises an error about unknown option `:dispatcher`

  #116 opened 2 years ago by linusdm
  4

• :no_proc errors when GenStage finishes quickly

  #114 opened 3 years ago by simonmcconnell
  7

• Need help understanding back pressure

  #113 opened 3 years ago by narrowtux
  1

• Session windows are mentioned as supported but are not

  #111 opened 3 years ago by wrgoldstein
  1

• Exceptions in Flow killing parent Oban process

  #110 opened 3 years ago by cigrainger
  4

• Unhelpful Error Message

  #109 opened 3 years ago by TylerPachal
  3

• Flow outlives a Task that starts it

  #100 opened 5 years ago by ACBullen
  1

• noproc errors - connecting finite GenStage to Flow.partition

  #91 opened 5 years ago by sunaku
  2

• Flow.map_batch/2 fails with CaseClauseError

  #95 opened 5 years ago by jeroenvisser101
  5

• Flow.from_specs and failed starts

  #78 opened 5 years ago by isaacsanders
  4

• Race condition when a producer is closing too soon

  #76 opened 6 years ago by Fenntasy
  3

• Possible Issue With Flow.through_specs/3

  #92 opened 5 years ago by ninjanicely
  2

• segmentation fault

  #89 opened 5 years ago by larskluge
  6

• from_stages - noproc errors when GenStage producer finishes early

  #88 opened 5 years ago by sunaku
  4

• error logged, but works?

  #86 opened 5 years ago by isaac-rstor
  4

• Spec Incorrect in Flow.into_specs/3

  #87 opened 6 years ago by asummers
  1

• bypassing to next partition (eliminating passthrough traffic)

  #85 opened 6 years ago by sunaku
  4

• GenServer.start/3 Dialyzer Issues in Flow.Coordinator

  #82 opened 6 years ago by asummers
  2

• Clarify :full_outer v :outer joins

  #81 opened 6 years ago by asummers
  1

• Carve events into windows by count and timeout

  #79 opened 6 years ago by garthk
  1

• Memory usage for side-effect only flows is high using Flow.each instead of Flow.map

  #74 opened 6 years ago by methyl
  1

• provide from/into/through_flows() to connect flows

  #72 opened 6 years ago by sunaku
  2

• `emit_and_reduce/3` doesn't keep the shape of accumulator

  #68 opened 6 years ago by wrachwal
  0

• Unexpected parallelism with Flow.from_enumerables

  #62 opened 6 years ago by lackac
  1

• Setup CI

  #60 opened 6 years ago by lackac
  3

• Rare race condition in tests

  #64 opened 6 years ago by lackac
  0

• Flow.partition should default to demand dispatcher if the number of stages is 1

  #43 opened 7 years ago by josevalim
  0

• Naming Stages

  #48 opened 7 years ago by isaacsanders
  4

• into_collectable/2 and through_collectable/2 to complement from_enumerable(s)/1

  #49 opened 7 years ago by tsutsu
  2

• Flow.fork_join? or I may be thinking of this wrong

  #51 opened 7 years ago by stevehebert
  1

• Provide a better mechanism for external GenStages to participate in Flows

  #52 opened 6 years ago by CptnKirk
  10

• Not able to run map stages after reduce

  #55 opened 6 years ago by lackac
  5

• Passing a stream to Flow.from_enumerable is not behaving as expected

  #24 opened 8 years ago by frekw
  4

• Non existent link to GenStage.async_notify/2 in docs

  #25 opened 8 years ago by mbaeuerle
  4

• Sliding Window implementation

  #26 opened 7 years ago by leifg
  2

• Race condition in `bounded_join` for large subscribe messages

  #28 opened 7 years ago by asonge
  1

• Termination of consuming streams is happen prematurely

  #31 opened 7 years ago by josevalim
  1

• max_demand from Enum seems wrong

  #33 opened 7 years ago by ijcd
  2

• Flow.partition does not route data to the right stage

  #34 opened 7 years ago by veetase
  8

• Error in flow source not stoping parent process in a timely manner

  #35 opened 7 years ago by juanperi
  8

• Proposal: scan operator

  #37 opened 7 years ago by mfclarke
  2

• Expose timeout parameter passed to GenStage.sync_subscribe

  #38 opened 7 years ago by ben-pr-p
  3

• How to catch exceptions?

  #39 opened 7 years ago by KamilLelonek
  3

• Flow exiting with normal reason

  #40 opened 7 years ago by TylerPachal
  2

• Keep getting this error when running a release.

  #10 opened 8 years ago by jackalcooper
  0

• Error on sync/async subscribe to pid(s)/atom(s) returned from into_stages

  #12 opened 8 years ago by zeeshanlakhani
  7

• Error for Flow.partition(key: { :elem, pos })

  #17 opened 8 years ago by loguntsov
  1

• Duplication of elements for complex flow

  #18 opened 8 years ago by loguntsov
  1

• Possibly inaccurate doc about the use of partition

  #21 opened 8 years ago by Arkham
  9