Package io.bytestreams.exchange.core

Class ServerSocketTransportFactory

java.lang.Object

io.bytestreams.exchange.core.ServerSocketTransportFactory

All Implemented Interfaces:

TransportFactory, Closeable, AutoCloseable

public final class ServerSocketTransportFactory
extends Object
implements TransportFactory, Closeable

A TransportFactory that accepts incoming TCP connections on a ServerSocket.

Each call to create() blocks until a client connects, applies the SocketConfigurator to the accepted socket, and returns a SocketTransport.

The factory owns the ServerSocket and binds it eagerly in ServerSocketTransportFactory.Builder.build(). Close the factory to stop accepting connections.

Use builder(int) to configure the bind address, backlog, and socket options.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ServerSocketTransportFactory.Builder

Method Summary

Modifier and Type	Method	Description
static ServerSocketTransportFactory.Builder	builder(int port)
void	close()
Transport	create()	Creates a new transport.
int	port()	Returns the local port this factory is bound to.

Methods inherited from class java.lang.Object

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

Method Details

builder

public static ServerSocketTransportFactory.Builder builder(int port)

port

public int port()

Returns the local port this factory is bound to.

create

public Transport create()
                 throws IOException

Description copied from interface: TransportFactory

Creates a new transport.

Specified by:

create in interface TransportFactory

Returns:

the new transport

Throws:

IOException - if the transport cannot be created

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException