File tree Expand file tree Collapse file tree 1 file changed +10
-10
lines changed
Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -349,18 +349,18 @@ private def unsubscribe (bd : Bounded.Receiver α) : IO Unit := do
349349 | .ok _ => pure ()
350350
351351private def tryRecv'
352- [Monad m] [MonadLiftT (ST IO.RealWorld) m] [MonadLiftT BaseIO m]
353- (receiverId : Nat) : AtomicT (Bounded.State α) m (Option α) := do
354- let st ← get
352+ [Monad m] [MonadLiftT (ST IO.RealWorld) m] [MonadLiftT BaseIO m]
353+ (receiverId : Nat) : AtomicT (Bounded.State α) m (Option α) := do
354+ let st ← get
355355
356- let some next := st.receivers[receiverId]?
357- | return none
356+ let some next := st.receivers[receiverId]?
357+ | return none
358358
359- if let some val ← getValueByPosition next then
360- modify ({ · with receivers := st.receivers.modify receiverId (· + 1 ) })
361- return some val
362- else
363- return none
359+ if let some val ← getValueByPosition next then
360+ modify ({ · with receivers := st.receivers.modify receiverId (· + 1 ) })
361+ return some val
362+ else
363+ return none
364364
365365private def tryRecv (ch : Bounded.Receiver α) : BaseIO (Option α) :=
366366 ch.state.atomically (tryRecv' ch.id)
You can’t perform that action at this time.
0 commit comments