@Test
void shouldWriteAndFlushInEventLoopThread() throws Exception
{

    testWriteInEventLoop( "WriteAndFlushSingleMessage",
            connection -> connection.writeAndFlush( new RunMessage( "RETURN 1" ), NO_OP_HANDLER ) );
    testWriteInEventLoop( "WriteAndFlushMultipleMessages",
            connection -> connection.writeAndFlush( new RunMessage( "RETURN 1" ), NO_OP_HANDLER, PULL_ALL, NO_OP_HANDLER ) );
}