@@ -539,135 +539,6 @@ public void doListIndexedArrayOfObjectsToArrayOfObjects() {
539539 });
540540 }
541541
542- @ Test
543- @ MetafixToDo ("implement Fix-style binds with collectors?" )
544- public void ifInCollector () {
545- MetafixTestHelpers .assertFix (streamReceiver , Arrays .asList (
546- "do entity('author')" ,
547- " map('name')" ,
548- " if all_contain('name', 'University')" ,
549- " add_field('type', 'Organization')" ,
550- " end" ,
551- "end" ),
552- i -> {
553- i .startRecord ("1" );
554- i .literal ("name" , "A University" );
555- i .endRecord ();
556- }, o -> {
557- o .get ().startRecord ("1" );
558- o .get ().startEntity ("author" );
559- o .get ().literal ("type" , "Organization" );
560- o .get ().literal ("name" , "A University" );
561- o .get ().endEntity ();
562- o .get ().endRecord ();
563- });
564- }
565-
566- @ Test
567- @ MetafixToDo ("implement Fix-style binds with collectors?" )
568- public void ifInCollectorMultiRecords () {
569- MetafixTestHelpers .assertFix (streamReceiver , Arrays .asList (
570- "do entity('author')" ,
571- " map('name')" ,
572- " if all_contain('name', 'University')" ,
573- " add_field('type', 'Organization')" ,
574- " end" ,
575- "end" ),
576- i -> {
577- i .startRecord ("1" );
578- i .literal ("name" , "Max" );
579- i .endRecord ();
580-
581- i .startRecord ("2" );
582- i .literal ("name" , "A University" );
583- i .endRecord ();
584-
585- i .startRecord ("3" );
586- i .literal ("name" , "Mary" );
587- i .endRecord ();
588- }, o -> {
589- o .get ().startRecord ("1" );
590- o .get ().startEntity ("author" );
591- o .get ().literal ("name" , "Max" );
592- o .get ().endEntity ();
593- o .get ().endRecord ();
594-
595- o .get ().startRecord ("2" );
596- o .get ().startEntity ("author" );
597- o .get ().literal ("type" , "Organization" );
598- o .get ().literal ("name" , "A University" );
599- o .get ().endEntity ();
600- o .get ().endRecord ();
601-
602- o .get ().startRecord ("3" );
603- o .get ().startEntity ("author" );
604- o .get ().literal ("name" , "Mary" );
605- o .get ().endEntity ();
606- o .get ().endRecord ();
607- });
608- }
609-
610- @ Test
611- @ MetafixToDo ("implement Fix-style binds with collectors?" )
612- public void ifInCollectorChoose () {
613- MetafixTestHelpers .assertFix (streamReceiver , Arrays .asList (
614- "do choose(flushWith: 'record')" ,
615- " if all_contain('name', 'University')" ,
616- " add_field('type', 'Organization')" ,
617- " end" ,
618- "end" ),
619- i -> {
620- i .startRecord ("1" );
621- i .literal ("name" , "Max University" );
622- i .endRecord ();
623-
624- i .startRecord ("2" );
625- i .literal ("name" , "Max Musterman" );
626- i .endRecord ();
627- }, o -> {
628- o .get ().startRecord ("1" );
629- o .get ().literal ("type" , "Organization" );
630- o .get ().endRecord ();
631-
632- o .get ().startRecord ("2" );
633- o .get ().endRecord ();
634- });
635- }
636-
637- @ Test
638- @ MetafixToDo ("implement Fix-style binds with collectors?" )
639- public void ifInCollectorCombine () {
640- MetafixTestHelpers .assertFix (streamReceiver , Arrays .asList (
641- "do combine(name: 'fullName', value: '${first} ${last}')" ,
642- " if all_contain('author.type', 'Person')" ,
643- " map('author.first', 'first')" ,
644- " map('author.last', 'last')" ,
645- " end" ,
646- "end" ),
647- i -> {
648- i .startRecord ("1" );
649- i .startEntity ("author" );
650- i .literal ("type" , "Organization" );
651- i .endEntity ();
652- i .endRecord ();
653-
654- i .startRecord ("2" );
655- i .startEntity ("author" );
656- i .literal ("first" , "Max" );
657- i .literal ("last" , "Musterman" );
658- i .literal ("type" , "DifferentiatedPerson" );
659- i .endEntity ();
660- i .endRecord ();
661- }, o -> {
662- o .get ().startRecord ("1" );
663- o .get ().endRecord ();
664-
665- o .get ().startRecord ("2" );
666- o .get ().literal ("fullName" , "Max Musterman" );
667- o .get ().endRecord ();
668- });
669- }
670-
671542 private void shouldIterateOverList (final String path , final int expectedCount ) {
672543 MetafixTestHelpers .assertFix (streamReceiver , Arrays .asList (
673544 "set_array('trace')" ,
0 commit comments