fixed possible lost of event in situation many readers, few writers in unbuffered streams.

Author: rssh

jvm/src/main/scala/gopher/impl/GuardedSPSCBufferedChannel.scala

@@ -81,7 +81,6 @@ taskExecutor: ExecutorService) extends GuardedSPSCBaseChannel[F,A](gopherApi,con
       while(progress) {
         progress = false
         if !state.isEmpty() then 
-          val a = state.startRead()
           progress |= processReadsStep()
         else
           if isClosed then 

jvm/src/main/scala/gopher/impl/GuardedSPSCUnbufferedChannel.scala

@@ -54,6 +54,10 @@ class GuardedSPSCUnbufferedChannel[F[_]:CpsAsyncMonad,A](
                           progress = true
                           progressWaitReader(reader)
                 }
+                if !writersLoopDone then
+                   // we have reader, should return one back if we want to start again
+                   // TODO: write test for this case
+                   readers.addFirst(reader)
         }
         if (isClosed && (readers.isEmpty || writers.isEmpty) ) then
           progress |= processWriteClose()