For debugging purposes I want to log every element...

# coroutines

[r4zzz4k]

For debugging purposes I want to log every element going through the channel. Is there any better way to do it than this?

class LoggingLinkedListChannel<E>(private val tag: String): LinkedListChannel<E>() {
	override fun offerInternal(element: E): Any {
		println("[$tag] $element")
		return super.offerInternal(element)
	}
}
val chan = LoggingLinkedListChannel<Int>("tag") // was Channel<Int>(Channel.UNLIMITED)

Is it even valid way to do this? It seems to be working for my simple use-case, but still.

As another way to do that was trying to get this working with .map { println(it); it }, but it throws away capacity as it's effectively creates another channel.

[elizarov]

That is the way to do it ATM.

[r4zzz4k]

Okay, thanks for confirmation!