com.github.pgasync.impl

Interface PgProtocolStream

All Known Implementing Classes:

NettyPgProtocolStream

public interface PgProtocolStream

Stream of messages from/to backend server.

Author:

Antti Laisi

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect(StartupMessage startup, java.util.function.Consumer<java.util.List<Message>> replyTo)
boolean	isConnected()
void	send(java.util.List<Message> message, java.util.function.Consumer<java.util.List<Message>> replyTo)
void	send(Message message, java.util.function.Consumer<java.util.List<Message>> replyTo)

Method Detail

connect

void connect(StartupMessage startup,
             java.util.function.Consumer<java.util.List<Message>> replyTo)

send

void send(Message message,
          java.util.function.Consumer<java.util.List<Message>> replyTo)

send

void send(java.util.List<Message> message,
          java.util.function.Consumer<java.util.List<Message>> replyTo)

isConnected

boolean isConnected()

close

void close()