Package org.bitcoinj.net

Class NioClient

java.lang.Object

org.bitcoinj.net.NioClient

All Implemented Interfaces:

MessageWriteTarget

public class NioClient
extends Object
implements MessageWriteTarget

Creates a simple connection to a server using a StreamConnection to process data.

Constructor Summary

Constructors

Constructor	Description
NioClient(SocketAddress serverAddress, StreamConnection parser, Duration connectTimeout)	Creates a new client to the given server address using the given StreamConnection to decode the data.

Method Summary

Modifier and Type	Method	Description
void	closeConnection()	Closes the connection to the server, triggering the StreamConnection.connectionClosed() event on the network-handling thread where all callbacks occur.
ListenableCompletableFuture<Void>	writeBytes(byte[] message)	Writes the given bytes to the remote server.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NioClient

public NioClient(SocketAddress serverAddress,
 StreamConnection parser,
 Duration connectTimeout)
          throws IOException

Creates a new client to the given server address using the given StreamConnection to decode the data. The given connection MUST be unique to this object. This does not block while waiting for the connection to open, but will call either the StreamConnection.connectionOpened() or StreamConnection.connectionClosed() callback on the created network event processing thread.

Parameters:

serverAddress - socket address of the server to connect to

parser - parses data from the server

connectTimeout - timeout for establishing a connection to the server, or ZERO for no timeout

Throws:

IOException

Method Details

closeConnection

public void closeConnection()

Description copied from interface: MessageWriteTarget

Closes the connection to the server, triggering the StreamConnection.connectionClosed() event on the network-handling thread where all callbacks occur.

Specified by:

closeConnection in interface MessageWriteTarget

writeBytes

public ListenableCompletableFuture<Void> writeBytes(byte[] message)
                                             throws IOException

Description copied from interface: MessageWriteTarget

Writes the given bytes to the remote server. The returned future will complete when all bytes have been written to the OS network buffer.

Specified by:

writeBytes in interface MessageWriteTarget

Throws:

IOException