Package s2.client

Class StreamClient

java.lang.Object

s2.client.BaseClient

s2.client.BasinClient

s2.client.StreamClient

All Implemented Interfaces:

AutoCloseable

public class StreamClient
extends BasinClient

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	StreamClient.AppendSessionRequestStream

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<AppendOutput>	append(AppendInput request)
StreamClient.AppendSessionRequestStream	appendSession(Consumer<AppendOutput> onResponse, Consumer<Throwable> onError, Runnable onComplete)
com.google.common.util.concurrent.ListenableFuture<Long>	checkTail()
ManagedAppendSession	managedAppendSession()
ManagedReadSession	managedReadSession(ReadSessionRequest request, Integer maxBufferedBytes)
com.google.common.util.concurrent.ListenableFuture<ReadOutput>	read(ReadRequest request)
ReadSession	readSession(ReadSessionRequest request, Consumer<ReadOutput> onResponse, Consumer<Throwable> onError)

Methods inherited from class s2.client.BasinClient

createStream, deleteStream, getStreamConfig, listStreams, reconfigureStream, streamClient

Methods inherited from class s2.client.BaseClient

close

Methods inherited from class java.lang.Object

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

Method Details

checkTail

public com.google.common.util.concurrent.ListenableFuture<Long> checkTail()

read

public com.google.common.util.concurrent.ListenableFuture<ReadOutput> read(ReadRequest request)

readSession

public ReadSession readSession(ReadSessionRequest request,
 Consumer<ReadOutput> onResponse,
 Consumer<Throwable> onError)

managedReadSession

public ManagedReadSession managedReadSession(ReadSessionRequest request,
 Integer maxBufferedBytes)

append

public com.google.common.util.concurrent.ListenableFuture<AppendOutput> append(AppendInput request)

appendSession

public StreamClient.AppendSessionRequestStream appendSession(Consumer<AppendOutput> onResponse,
 Consumer<Throwable> onError,
 Runnable onComplete)

managedAppendSession

public ManagedAppendSession managedAppendSession()