Skip to content

Instantly share code, notes, and snippets.

@shvalb
shvalb / AsyncClientConnector
Last active March 17, 2018 19:34
Vertx NetClient used with JsonParser - Only returns the 1st message
package com.luckyrhinos.sbg.robots;
import static io.vertx.core.parsetools.JsonEventType.VALUE;
import static org.awaitility.Awaitility.await;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import org.junit.Test;
@shvalb
shvalb / XMLParser.java
Created July 29, 2016 14:44
Async Parsing XML using Aalto-XML
import javax.xml.stream.*;
import javax.xml.stream.events.*;
import com.fasterxml.aalto.*;
import com.fasterxml.aalto.stax.*;
import io.vertx.core.buffer.*;
@shvalb
shvalb / gist:0022fc6a7c8662b80f1b3631329b89b4
Last active July 29, 2016 15:38
Async Parsing multiple XML docs from socket
private void processMessages(ReadStream<Buffer> f) {
AsyncXMLParser parser = new AsyncXMLParser();
f.toObservable()
.map(buf -> (io.vertx.core.buffer.Buffer)buf.getDelegate())
.flatMap(parser::feed)
.doOnNext(element -> {
switch(element.getType()) {
case XMLEvent.START_DOCUMENT:
// TODO: Create a new class object here.
@shvalb
shvalb / Tester.java
Last active December 17, 2019 18:48
Working with Observable.create
import java.io.*;
import javax.xml.parsers.*;
import javax.xml.transform.*;
import javax.xml.transform.dom.*;
import javax.xml.transform.stream.*;
import org.w3c.dom.*;
import io.vertx.core.*;
@shvalb
shvalb / AsyncXMLParser.java
Last active October 4, 2022 18:38
Async XML Parser using Aalto and Vertx
/**********************************************
* LICENSE
* --------
* https://github.com/georocket/georocket#license
* http://www.apache.org/licenses/LICENSE-2.0
**********************************************/
package xml;