public class ParserBase extends Object
| Constructor and Description |
|---|
ParserBase(Protocol protocol,
String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
| Modifier and Type | Method and Description |
|---|---|
String |
getName() |
static ByteBuffer |
serialize(Protocol protocol,
Iterable<Value<?>> record) |
protected CompletableFuture<?> |
transmit(RecordProvider packet,
InetSocketAddress remoteAddress) |
public ParserBase(Protocol protocol, String name, AsyncDispatcher<TelemetryMessage> dispatcher)
public String getName()
protected CompletableFuture<?> transmit(RecordProvider packet, InetSocketAddress remoteAddress) throws Exception
Exceptionpublic static ByteBuffer serialize(Protocol protocol, Iterable<Value<?>> record)
Copyright © 2019. All rights reserved.