@Test
void shouldWriteInEventLoopThread() throws Exception
{

    testWriteInEventLoop( "WriteSingleMessage",
            connection -> connection.write( new RunMessage( "RETURN 1" ), NO_OP_HANDLER ) );
    testWriteInEventLoop( "WriteMultipleMessages",
            connection -> connection.write( new RunMessage( "RETURN 1" ), NO_OP_HANDLER, PULL_ALL, NO_OP_HANDLER ) );
}