Add Channel#closeWithElement

core/shared/src/main/scala/fs2/concurrent/Channel.scala

@@ -176,7 +176,7 @@ object Channel {
                       State(values, size, None, (a, producer) :: producers, close),
                       signalClosure.whenA(close) *>
                         notifyStream(waiting).as(rightUnit) <*
-                        waitOnBound(producer, poll)
+                        waitOnBound(producer, poll).whenA(!close)
                     )
               }
             }

core/shared/src/test/scala/fs2/concurrent/ChannelSuite.scala

@@ -277,6 +277,12 @@ class ChannelSuite extends Fs2Suite {
     checkIfSendAndCloseClosing(channel).parReplicateA_(if (isJVM) 10000 else 1)
   }
 
+  test("sendAndClose closes right after sending the last element in synchronous case") {
+    val channel = Channel.synchronous[IO, Int]
+
+    checkIfSendAndCloseClosing(channel).parReplicateA_(if (isJVM) 10000 else 1)
+  }
+
   def racingSendOperations(channel: IO[Channel[IO, Int]]) = {
     val expectedFirstCase = ((Right(()), Right(())), List(0, 1))
     val expectedSecondCase = ((Right(()), Left(Channel.Closed)), List(1))