We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e9b4d54 commit 1755e09Copy full SHA for 1755e09
net.lecousin.core/src/main/java/net/lecousin/framework/xml/XMLStreamReaderAsync.java
@@ -116,13 +116,10 @@ public ISynchronizationPoint<Exception> startRootElement() {
116
return nextStartElement();
117
}
118
SynchronizationPoint<Exception> sp = new SynchronizationPoint<>();
119
- start.listenAsync(new Next(sp) {
120
- @Override
121
- protected void onNext() {
122
- if (Type.START_ELEMENT.equals(event.type)) sp.unblock();
123
- else nextStartElement().listenInline(sp);
124
- }
125
- }, sp);
+ start.listenAsync(new ParsingTask(() -> {
+ if (Type.START_ELEMENT.equals(event.type)) sp.unblock();
+ else nextStartElement().listenInline(sp);
+ }), sp);
126
return sp;
127
128
0 commit comments