@Test
void shouldWriteAndFlushSingleMessage()
{

    EmbeddedChannel channel = newChannel();
    NetworkConnection connection = newConnection( channel );
    connection.writeAndFlush( PULL_ALL, NO_OP_HANDLER );
    channel.runPendingTasks(); // writeAndFlush is scheduled to execute in the event loop thread, trigger its execution
    assertEquals( 1, channel.outboundMessages().size() );
    assertEquals( PULL_ALL, single( channel.outboundMessages() ) );
}