decode

suspend fun decode(s: AsyncStream)