public interface StreamSubscriber
void
onTuple(Stream stream, Tuple tuple)
streamClosed(Stream stream)
void onTuple(Stream stream, Tuple tuple)
void streamClosed(Stream stream)
Copyright © 2017 Space Applications Services. All rights reserved.