Package com.arangodb.vst.internal

Class VstConnectionAsync

java.lang.Object

com.arangodb.vst.internal.VstConnection<CompletableFuture<Message>>

com.arangodb.vst.internal.VstConnectionAsync

All Implemented Interfaces:

Connection, Closeable, AutoCloseable

public class VstConnectionAsync
extends VstConnection<CompletableFuture<Message>>

Author:

Mark Vollmary

Field Summary

Fields inherited from class com.arangodb.vst.internal.VstConnection

messageStore, timeout

Constructor Summary

Constructors

Constructor	Description
VstConnectionAsync(ArangoConfig config, HostDescription host)

Method Summary

Modifier and Type	Method	Description
protected void	doKeepAlive()
CompletableFuture<InternalResponse>	executeAsync(InternalRequest request)
CompletableFuture<Message>	write(Message message, Collection<Chunk> chunks)

Methods inherited from class com.arangodb.vst.internal.VstConnection

close, isOpen, open, readBytesIntoBuffer, readChunk, sendKeepAlive, setJwt, writeIntern

Methods inherited from class java.lang.Object

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

Constructor Details

VstConnectionAsync

public VstConnectionAsync(ArangoConfig config,
 HostDescription host)

Method Details

write

public CompletableFuture<Message> write(Message message,
 Collection<Chunk> chunks)

Specified by:

write in class VstConnection<CompletableFuture<Message>>

doKeepAlive

protected void doKeepAlive()

Specified by:

doKeepAlive in class VstConnection<CompletableFuture<Message>>

executeAsync

public CompletableFuture<InternalResponse> executeAsync(InternalRequest request)