@Test
void shouldWriteSingleMessage()
{

    EmbeddedChannel channel = newChannel();
    NetworkConnection connection = newConnection( channel );
    connection.write( PULL_ALL, NO_OP_HANDLER );
    assertEquals( 0, channel.outboundMessages().size() );
    channel.flushOutbound();
    assertEquals( 1, channel.outboundMessages().size() );
    assertEquals( PULL_ALL, single( channel.outboundMessages() ) );
}