public class LocalConnection extends Object implements Connection
| Constructor and Description |
|---|
LocalConnection(ThreadContext context) |
LocalConnection(ThreadContext context,
Set<LocalConnection> connections) |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Void> |
close() |
Listener<Connection> |
closeListener(Consumer<Connection> listener) |
LocalConnection |
connect(LocalConnection connection)
Connects the connection to another connection.
|
boolean |
equals(Object object) |
Listener<Throwable> |
exceptionListener(Consumer<Throwable> listener) |
<T,U> Connection |
handler(Class<T> type,
MessageHandler<T,U> handler) |
int |
hashCode() |
<T,U> CompletableFuture<U> |
send(T request) |
public LocalConnection(ThreadContext context)
public LocalConnection(ThreadContext context, Set<LocalConnection> connections)
public LocalConnection connect(LocalConnection connection)
public <T,U> CompletableFuture<U> send(T request)
send in interface Connectionpublic <T,U> Connection handler(Class<T> type, MessageHandler<T,U> handler)
handler in interface Connectionpublic Listener<Throwable> exceptionListener(Consumer<Throwable> listener)
exceptionListener in interface Connectionpublic Listener<Connection> closeListener(Consumer<Connection> listener)
closeListener in interface Connectionpublic CompletableFuture<Void> close()
close in interface ConnectionCopyright © 2013–2015. All rights reserved.