Hey, anyone know what's wrong with this test? ``` ...

# server

[filiplamparski]

Hey, anyone know what's wrong with this test?

@Test
    fun `Can register as an executor`() = runBlocking {
        val session = sessionFor("<ws://localhost:$port/ws/channel>")
        val msg = ObjectMapper().writeValueAsString(Message.executorConnected())
        session.send(session.textMessage(msg).toMono()).awaitFirst()
        Assertions.assertEquals(registry.getAll().size, 1)
        session.close().awaitFirst()
        Assertions.assertEquals(registry.getAll().size, 0)
    }