zesterer/flume

Issues

• Please support creating a Receiver from a Sender and vice versa

  #155 opened 2 months ago by joshtriplett
  1

• Resize the capacity of bounded channels

  #144 opened 8 months ago by Frando
  2

• Senders and receivers are both unusable in browser main thread in WASM

  #137 opened 4 months ago by white-axe
  0

• Performance with many senders on multi-threaded runtime

  #152 opened 5 months ago by Frando
  0

• chan.waiting `push_front` instead of `push_back`? Thread scheduling

  #150 opened 6 months ago by fulara
  1

• Memory leak in unbounded channels

  #146 opened 8 months ago by rakbladsvalsen
  1

• Clarify behavior rendezvous channels

  #145 opened 8 months ago by orlp
  10

• Add a `force_send()` function to `flume::Sender`?

  #142 opened 9 months ago by BTOdell
  0

• recv on an empty unbounded channel keeps the task busy.

  #141 opened a year ago by fulmicoton
  1

• Do we need to add a timeout for `recv_async`?

  #139 opened a year ago by zhuxiujia
  1

• `SendFut::poll` should return `Poll::Pending` for rendezvous channels when no item is queued

  #140 opened a year ago by thomaseizinger
  0

• Lost message when selecing on MPMC in loop from multiple threads

  #135 opened a year ago by asonix
  2

• Semantic violation that involves rendezvous channel and selector

  #134 opened a year ago by sgdxbc
  4

• async selector

  #133 opened a year ago by vortex314
  2

• MPMC Not working or no Broadcasting

  #132 opened a year ago by lsabi
  3

• Document cancel safety

  #104 opened 2 years ago by madadam
  16

• The last messge won't be triggered in async code block.

  #124 opened a year ago by SethWen
  8

• Generic over backing storage / statically allocated bounded channels

  #131 opened a year ago by kyrias
  1

• Document features

  #129 opened a year ago by kyrias
  1

• Question: Fairness when multiple receivers are doing work-stealing

  #128 opened a year ago by GermanCoding
  2

• Update benchmarks to reflect current performance

  #114 opened 2 years ago by TimonPost
  2

• `async`: `send_timeout` & `send_deadline`

  #125 opened 2 years ago by NathanSWard
  3

• `flume::Sender<T>` stops to send messages to `flume::Receiver<T>` when passed through `.await` point

  #122 opened 2 years ago by vikulikov
  2

• Race condition in the async code when sender drops too quickly

  #120 opened 2 years ago by inetic
  1

• Awaiting disconnection of Receiver or Sender

  #119 opened 2 years ago by Kijewski
  2

• Allow using `into_stream()` with non-`'static` items

  #106 opened 2 years ago by Seeker14491
  4

• SendError cannot be sent between threads?

  #116 opened 2 years ago by stevefan1999-personal
  1

• Remove lifetime constraint on Reciever.drain()

  #113 opened 2 years ago by wyatt-herkamp
  2

• Expose sender_count / receiver_count to the user

  #110 opened 2 years ago by coolreader18
  0

• Add a `WeakSender`?

  #107 opened 2 years ago by phil-opp
  4

• Slow results with Multi Consumer, Single Producer

  #105 opened 2 years ago by Bobonium
  3

• Memory leak caused by polling `RecvStream`

  #88 opened 2 years ago by jsdw
  1

• Example showing request + response

  #101 opened 3 years ago by brandonros
  5

• Values received out-of-order in a single-threaded async single-producer single-consumer scenario (involving tokio::select).

  #98 opened 3 years ago by rzheka
  6

• Consider adding into_iter()

  #96 opened 3 years ago by lu-zero
  4

• Future structs don't have `#[must_use]` attributes

  #93 opened 3 years ago by Aeledfyr
  1

• Feature: broadcast

  #92 opened 3 years ago by Antiarchitect
  2

• Question: Is Flume production ready?

  #73 opened 4 years ago by ev94
  4

• catch_unwind and Flume channels

  #90 opened 3 years ago by itamarst
  3

• Disconnecting a channel should, perhaps, drop unreceived messages

  #89 opened 3 years ago by itamarst
  6

• Spinlock exponential backoff has no cap — can hang all threads that touch the lock

  #74 opened 4 years ago by thomcc
  5

• error[E0658]: or-patterns syntax is experimental

  #83 opened 4 years ago by tarcieri
  3

• Consider implementing a way to try_send without consuming the message

  #82 opened 4 years ago by let4be
  4

• `Receiver` methods for `RecvFut` and `RecvStream` and `Sender` methods for `SendFut` and `SendSink`

  #80 opened 4 years ago by daxpedda
  0

• Add oneshot channel type

  #79 opened 4 years ago by lunacookies
  4

• `recv_async` returning Disconnected in some highly-concurrent situations even though `send` succeeds

  #78 opened 4 years ago by ecton
  3

• Question: Is message order through a channel preserved?

  #72 opened 4 years ago by jrobhoward
  1

• Why does sending require T: Unpin?

  #66 opened 4 years ago by Darksonn
  2

• Support broadcast channel

  #68 opened 4 years ago by maxjoehnk
  4

• Is there a reason not to provide a `Sender.subscribe() -> Receiver` method?

  #67 opened 4 years ago by coolreader18
  0