Package io.keldysh.messaging.parsing

Interface Parser<PAYLOAD,RECEIVE_MESSAGE,PUBLISH_MESSAGE>

All Known Subinterfaces:

ByteBufParser<PAYLOAD>, PayloadParser<PAYLOAD>

public interface Parser<PAYLOAD,RECEIVE_MESSAGE,PUBLISH_MESSAGE>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	Parser.Reader<RECEIVE_MESSAGE,PAYLOAD>
static interface	Parser.Writer<PAYLOAD,PUBLISH_MESSAGE>

Method Summary

Modifier and Type	Method	Description
static <T> Parser<T,T,T>	identity()
default PAYLOAD	read(RECEIVE_MESSAGE message)
Parser.Reader<RECEIVE_MESSAGE,PAYLOAD>	reader()
default PUBLISH_MESSAGE	write(PUBLISH_MESSAGE message, PAYLOAD payload)
Parser.Writer<PAYLOAD,PUBLISH_MESSAGE>	writer()

Method Details

read

default PAYLOAD read(RECEIVE_MESSAGE message)
              throws ParsingException

Throws:

ParsingException

write

default PUBLISH_MESSAGE write(PUBLISH_MESSAGE message,
 PAYLOAD payload)
                       throws ParsingException

Throws:

ParsingException

reader

Parser.Reader<RECEIVE_MESSAGE,PAYLOAD> reader()

writer

Parser.Writer<PAYLOAD,PUBLISH_MESSAGE> writer()

identity

static <T> Parser<T,T,T> identity()