@Test
void shouldCancelKeys()
{

    // Given
    RxResultCursor cursor = mock( RxResultCursorImpl.class );
    RxResult rxResult = newRxResult( cursor );
    List<String> keys = Arrays.asList( "one", "two", "three" );
    when( cursor.keys() ).thenReturn( keys );
    // When & Then
    StepVerifier.create( Flux.from( rxResult.keys() ).limitRate( 1 ).take( 1 ) )
            .expectNext( Arrays.asList( "one", "two", "three" ) )
            .verifyComplete();
}