18
18
import static org .mockito .Mockito .inOrder ;
19
19
import static org .mockito .Mockito .verifyNoMoreInteractions ;
20
20
21
- import org .culturegraph .mf .exceptions .FormatException ;
22
21
import org .culturegraph .mf .framework .StreamReceiver ;
23
- import org .culturegraph .mf .stream .converter .CGTextDecoder ;
24
- import org .culturegraph .mf .stream .sink .EventList ;
25
- import org .culturegraph .mf .stream .sink .StreamValidator ;
26
22
import org .culturegraph .mf .util .StreamConstants ;
27
23
import org .junit .After ;
28
- import org .junit .Assert ;
29
24
import org .junit .Before ;
30
25
import org .junit .Test ;
31
26
import org .mockito .InOrder ;
@@ -71,16 +66,18 @@ public void testShouldChangeIdsOfRecords() {
71
66
idChangePipe .startRecord (OLD_RECORD_ID1 );
72
67
idChangePipe .literal (StreamConstants .ID , NEW_RECORD_ID1 );
73
68
idChangePipe .endRecord ();
69
+
74
70
idChangePipe .startRecord (OLD_RECORD_ID2 );
75
71
idChangePipe .literal (StreamConstants .ID , NEW_RECORD_ID2 );
76
72
idChangePipe .endRecord ();
77
73
78
74
final InOrder ordered = inOrder (receiver );
79
75
ordered .verify (receiver ).startRecord (NEW_RECORD_ID1 );
80
- ordered .verify (receiver ).literal (StreamConstants .ID , NEW_RECORD_ID1 );
76
+ // ordered.verify(receiver).literal(StreamConstants.ID, NEW_RECORD_ID1);
81
77
ordered .verify (receiver ).endRecord ();
78
+
82
79
ordered .verify (receiver ).startRecord (NEW_RECORD_ID2 );
83
- ordered .verify (receiver ).literal (StreamConstants .ID , NEW_RECORD_ID2 );
80
+ // ordered.verify(receiver).literal(StreamConstants.ID, NEW_RECORD_ID2);
84
81
ordered .verify (receiver ).endRecord ();
85
82
}
86
83
@@ -98,7 +95,7 @@ public void testShouldKeepRecordsWithoutIdLiteral() {
98
95
ordered .verify (receiver ).literal (LITERAL_NAME , LITERAL_VALUE );
99
96
ordered .verify (receiver ).endRecord ();
100
97
ordered .verify (receiver ).startRecord (NEW_RECORD_ID2 );
101
- ordered .verify (receiver ).literal (StreamConstants .ID , NEW_RECORD_ID2 );
98
+ // ordered.verify(receiver).literal(StreamConstants.ID, NEW_RECORD_ID2);
102
99
ordered .verify (receiver ).endRecord ();
103
100
}
104
101
@@ -115,7 +112,7 @@ public void testShouldRemoveRecordsWithoutIdLiteral() {
115
112
116
113
final InOrder ordered = inOrder (receiver );
117
114
ordered .verify (receiver ).startRecord (NEW_RECORD_ID2 );
118
- ordered .verify (receiver ).literal (StreamConstants .ID , NEW_RECORD_ID2 );
115
+ // ordered.verify(receiver).literal(StreamConstants.ID, NEW_RECORD_ID2);
119
116
ordered .verify (receiver ).endRecord ();
120
117
verifyNoMoreInteractions (receiver );
121
118
}
@@ -145,8 +142,8 @@ public void testShouldUseLastIdLiteralAsNewId() {
145
142
146
143
final InOrder ordered = inOrder (receiver );
147
144
ordered .verify (receiver ).startRecord (NEW_RECORD_ID2 );
148
- ordered .verify (receiver ).literal (StreamConstants .ID , NEW_RECORD_ID1 );
149
- ordered .verify (receiver ).literal (StreamConstants .ID , NEW_RECORD_ID2 );
145
+ // ordered.verify(receiver).literal(StreamConstants.ID, NEW_RECORD_ID1);
146
+ // ordered.verify(receiver).literal(StreamConstants.ID, NEW_RECORD_ID2);
150
147
ordered .verify (receiver ).endRecord ();
151
148
}
152
149
0 commit comments