Package co.decodable.sdk.pipeline.testing

Interface DecodableStream<T>

Type Parameters:

T - The element type of this stream

public interface DecodableStream<T>

Represents a data stream on the Decodable platform.

Method Summary

Modifier and Type	Method	Description
void	add(StreamRecord<T> streamRecord)	Adds the given stream record to this stream.
Future<List<StreamRecord<T>>>	take(int n)	Retrieves n elements from this stream.
Future<StreamRecord<T>>	takeOne()	Retrieves one element from this stream.

Method Details

add

void add(StreamRecord<T> streamRecord)

Adds the given stream record to this stream.

takeOne

Future<StreamRecord<T>> takeOne()

Retrieves one element from this stream.

take

Future<List<StreamRecord<T>>> take(int n)

Retrieves n elements from this stream.