class DvrDataRepository implements DvrRepository {

    @SuppressWarnings( CONVERT2METHODREF )
    @Override
    public Observable<List<Encoder>> encoders() {
        Log.d( TAG, "encoders : enter" );

        final DvrDataStore dvrDataStore = this.dvrDataStoreFactory.createMasterBackendDataStore();

        return dvrDataStore.encoderEntityList()
                .doOnError( throwable -> Log.e( TAG, "encoders : error", throwable ) )
                .map( encoderEntities -> EncoderEntityDataMapper.transformCollection( encoderEntities ) );
    }

    @Inject public  DvrDataRepository( DvrDataStoreFactory dvrDataStoreFactory );

}