We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 20a44ae commit eb774c0Copy full SHA for eb774c0
core/shared/src/main/scala/fs2/concurrent/Topic.scala
@@ -221,7 +221,7 @@ object Topic {
221
222
def unsubscribe(id: Long): F[Unit] =
223
state.flatModify {
224
- case s @ State.Active(subs, nextId, _, _) =>
+ case s @ State.Active(subs, _, _, _) =>
225
// _After_ we remove the bounded channel for this
226
// subscriber, we need to drain it to unblock to
227
// publish loop which might have already enqueued
0 commit comments