HangingTraceStream constructor

HangingTraceStream(
  1. Stream<List<int>> stream,
  2. ExchangeService service
)
Initializes a new instance of the The stream. The service.

Implementation

HangingTraceStream(Stream<List<int>> stream, ExchangeService service) {
  this.underlyingStream = stream;
  // this.underlyingStream = StreamQueue(stream);
  this.service = service;
}