@Test
void shouldInstallRecordConsumerAndReportError() throws Throwable
{

    // Given
    RuntimeException error = new RuntimeException( "Hi" );
    BiConsumer recordConsumer = mock( BiConsumer.class );
    // When
    RunResponseHandler runHandler = newRunResponseHandler( error );
    PullResponseHandler pullHandler = new ListBasedPullHandler();
    RxResultCursor cursor = new RxResultCursorImpl( error, runHandler, pullHandler );
    cursor.installRecordConsumer( recordConsumer );
    // Then
    verify( recordConsumer ).accept( null, error );
    verifyNoMoreInteractions( recordConsumer );
}