org.yamcs.client.base

Class AbstractStreamSender<ItemT extends com.google.protobuf.Message,ResponseT>

java.lang.Object

org.yamcs.client.base.AbstractStreamSender<ItemT,ResponseT>

All Implemented Interfaces:

StreamSender<ItemT,ResponseT>

public class AbstractStreamSender<ItemT extends com.google.protobuf.Message,ResponseT>
extends Object
implements StreamSender<ItemT,ResponseT>

Constructor Summary

Constructors

Constructor and Description
AbstractStreamSender(BulkRestDataSender baseSender)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<ResponseT>	complete()
void	send(ItemT message)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractStreamSender

public AbstractStreamSender(BulkRestDataSender baseSender)

Method Detail

send

public void send(ItemT message)

Specified by:

send in interface StreamSender<ItemT extends com.google.protobuf.Message,ResponseT>

complete

public CompletableFuture<ResponseT> complete()

Specified by:

complete in interface StreamSender<ItemT extends com.google.protobuf.Message,ResponseT>