setupStream<T> method

  1. @protected
StreamData setupStream<T>(
  1. Stream<T> stream,
  2. {dynamic onData,
  3. dynamic onSubscribed,
  4. dynamic onError,
  5. dynamic onCancel,
  6. dynamic transformData}
)

Implementation

@protected
StreamData setupStream<T>(
  Stream<T> stream, {
  onData,
  onSubscribed,
  onError,
  onCancel,
  transformData,
}) {
  StreamData<T> streamData = StreamData<T>(
    stream,
    onData: onData,
    onSubscribed: onSubscribed,
    onError: onError,
    onCancel: onCancel,
    transformData: transformData,
  );
  streamData.initialise();

  return streamData;
}