Package 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	Description
AbstractStreamSender(BulkRestDataSender baseSender)

Method Summary

Modifier and Type	Method	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 Details

AbstractStreamSender

public AbstractStreamSender(BulkRestDataSender baseSender)

Method Details

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>