public class MessageReader<T> extends Endpoint
| Constructor and Description |
|---|
MessageReader(java.io.InputStream input,
java.lang.Class<T> msgType) |
| Modifier and Type | Method and Description |
|---|---|
T |
receive(java.util.function.Consumer<? super java.lang.String> unparsedOutputSink) |